【发布时间】:2021-07-29 10:57:10
【问题描述】:
我将 kafka 连接集群设置为分布式模式,我想获得与多个 kafka 集群的连接,而不仅仅是多个代理。
可以在connect-distributed.properties 中使用bootstrap.servers 设置目标代理。
因此,首先,我从 kafka-cluster-A 设置 broker1,如下所示:
bootstrap.servers=broker1:9092
当然,效果很好。
然后,我从 kafka-cluster-B 添加了 broker2,如下所示:
bootstrap.servers=broker1:9092,broker2:9092
因此,这两个代理位于不同的集群中。 这根本不起作用。 没有任何错误,它只是卡住了,并且没有像通过 REST API 创建连接器这样的请求得到答复。
如何连接多个 kafka 集群?
【问题讨论】:
标签: apache-kafka apache-kafka-connect