springboot + kafka SASL
版本:spring-boot:1.5.13.RELEASEkafka-client:2.4.1yml配置:kafka:# kafka集群地址bootstrap-servers: ip:1,ip2:2# KafkaProperties中的porprites属性,网上看的案例properties都配置再consumer和producer下,# 这里不行,可能是版本问题,这里的properties参数和
·
版本:
spring-boot:1.5.13.RELEASE
kafka-client:2.4.1
yml配置:
kafka:
# kafka集群地址
bootstrap-servers: ip:1,ip2:2
# KafkaProperties中的porprites属性,网上看的案例properties都配置再consumer和producer下,
# 这里不行,可能是版本问题,这里的properties参数和consumer平级
properties:
sasl.mechanism: SCRAM-SHA-256
security.protocol: SASL_PLAINTEXT
#注意结尾的; 必填,不填;报错 name 和 password替换成你自己kafka配置的账号密码
sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="name" password="password";
consumer:
enable-auto-commit: true
session-timeout: 6000
auto-commit-interval: 1000
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
autoOffsetReset: latest
concurrency: 20
topic: mytopic5
groupId: canal-test-group
producer:
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
参考:
更多推荐
所有评论(0)