spring云流将消息发送到confluent上托管的主题

xe55xuns 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(356)

我已经编写了一个springcloudstreammessageproducer，它成功地将有效负载发布到本地引导服务器上的主题。我想将有效负载发布到我在confluent cloud上创建的主题上。我需要进行哪些配置更改？下面是正在工作的localhost的配置。

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

apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

来源：https://stackoverflow.com/questions/65415350/spring-cloud-stream-to-send-message-to-topics-hosted-on-confluent

1条答案

按热度按时间

0dxa2lsx1#

你不再需要 zkNodes -现代Kafka的客户只直接与经纪人交谈，而不与Zookeeper交谈。您使用的是什么版本的SpringCloudStream？该属性（zknodes）在最新版本中不再存在。
你需要设置 brokers 属性来匹配在代理服务器中配置为播发侦听器的主机/端口的内容 server.properties 文件夹。

赞(0）回复(0）举报 2021-06-04

我来回答

spring云流将消息发送到confluent上托管的主题

1条答案

相关问题

热门标签

最新问答