Spring云流向Confluent上托管的主题发送消息

Question

我已经编写了一个Spring云流消息生成器，它成功地将有效负载发布到我的本地引导服务器上的主题中。我想把有效载荷发布到我在Confluent Cloud上创建的主题上。我需要进行哪些配置更改？下面是正在工作的localhost的配置。

spring:
cloud:
stream:
bindings:
output:
destination: ordersTopic
content-type: application/json
kafka:
binder:
zkNodes: localhost
brokers: localhost
default-binder: kafka

Answer 1

您不再需要zkNodes-现代Kafka客户端只与broker直接对话，而不与zookeeper对话。你在用什么版本的春云流？该属性(zkNodes(在最近的版本中不再存在。

您需要将brokers属性设置为匹配代理的server.properties文件中被配置为播发侦听器的主机/端口的任何属性。