KAFKA
quickmsg
# 配置详解
| 参数 | 说明 | 必传 | 默认值 |
|---|---|---|---|
| source | 类型 | 是 | KAFKA |
| sourceName | 数据源名称 | 是 | 无 |
| sourceAttributes | 额外参数 | 否 | 无 |
smqtt:
sources: # 配置数据源sources
- source: KAFKA # kafka配置
sourceName: kafka
sourceAttributes:
topic: testTopic
bootstrap-servers: 172.16.63.50:9092
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
1
2
3
4
5
6
7
8
9
2
3
4
5
6
7
8
9
支持kafka原生所有配置参数，将.使用-替换即可,sourceAttributes设置时候可以设置topic,否则默认smqtt