KAFKA

# 配置详解

参数 说明 必传 默认值
source 类型 KAFKA
sourceName 数据源名称
sourceAttributes Kafka Producer参数
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

支持kafka原生所有配置参数,将.使用-替换即可,sourceAttributes设置时候可以设置topic,否则默认smqtt

Last Updated: 4/21/2023, 8:17:29 AM