Kafka Endpoint
Kafka Endpoint 用来创建和启动Kafka订阅服务，它可以订阅不同主题数据，然后路由到不同规则链进行处理。
提示
该组件是扩展组件，需要引入额外的扩展库：rulego-components (opens new window)
# Type
endpoint/kafka
# 启动配置
| 字段 | 类型 | 是否必填 | 说明 | 默认值 |
|---|---|---|---|---|
| Brokers | []string | 是 | kafka服务器地址列表 | - |
| groupId v0.23.0+ | string | 否 | 消费者组ID | rulego |
# 响应
exchange.Out.SetBody响应之前，需要通过exchange.Out.Headers()或者exchange.Out.Msg.Metadata指定responseTopic参数，组件就会往指定的主题发送数据：
exchange.Out.GetMsg().Metadata.PutValue("responseTopic", "device.msg.response")
// or
exchange.Out.Headers().Add("responseTopic", "device.msg.response")
exchange.Out.SetBody([]byte("ok"))
1
2
3
4
5
2
3
4
5
响应参数配置：
| 字段 | 类型 | 是否必填 | 说明 | 默认值 |
|---|---|---|---|---|
| responseTopic | string | 是 | 主题 | - |
| partition | int | 否 | 分区 | 0 |
| key | string | 否 | 分区Key | - |
# 示例
以下是使用endpoint的示例代码：
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/10/23, 10:13:01