赞
踩
在代码中是用kafkaTemplate去操作kafka,却发现一直连接不上,sasl的配置全都配置正确,使用kafkaProducer 可以正常发送与消费消息
原来是nacos配置出现问题:
kafka:
bootstrap-servers: 127.0.0.1:8899
producer: # producer 生产者
retries: 0 # 重试次数
acks: 1 # 应答级别:多少个分区副本备份完成时向生产者发送ack确认(可选0、1、all/-1)
batch-size: 16384 # 批量大小
buffer-memory: 33554432 # 生产端缓冲区大小
key-serializer: org.apache.kafka.common.serialization.StringSerializer
# value-serializer: com.itheima.demo.config.MySerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
properties:
security.protocol: SASL_PLAINTEXT
sasl.mechanism: SCRAM-SHA-512
sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="xxx" password="xxx";
需要加入 properties,一开始以为sasl.jaas.config 需要向上面一样改为sasl-jaas-config 原来不需要
希望各位大佬解惑, 为啥上面可以配batch-size 以’-'分隔 而下面却是以"."分隔
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。