我已经编写了一个springcloudstreammessageproducer，它成功地将有效负载发布到本地引导服务器上的主题。我想将有效负载发布到我在confluent cloud上创建的主题上。我需要进行哪些配置更改？下面是正在工作的localhost的配置。
spring:
cloud:
stream:
bindings:
output:
destination: ordersTopic
content-type: application/json
kafka:
binder:
zkNodes: localhost
brokers: localhost
default-binder: kafka
1条答案
按热度按时间0dxa2lsx1#
你不再需要
zkNodes-现代Kafka的客户只直接与经纪人交谈，而不与Zookeeper交谈。您使用的是什么版本的SpringCloudStream？该属性（zknodes）在最新版本中不再存在。你需要设置
brokers属性来匹配在代理服务器中配置为播发侦听器的主机/端口的内容server.properties文件夹。