我有一个springboot(2.3.3)服务,使用springkafka访问专用的kafka/zookeeper配置。我一直在使用application.properties设置spring.kafka.bootstrap-servers=localhost:9092 to 访问我的开发/测试apache kafka服务。
但是,在生产中,我们在zookeeper中配置了一个kafka代理集群(在许多服务器上),我被要求修改服务以查询zookeeper以获得代理列表,并使用该列表而不是引导服务器配置。原因是,我们的devops人员已经知道要重新配置服务器/节点和kafka代理。
基本上,我被要求使我的服务与apachekafka代理运行的位置无关。我的服务只需要知道如何从zookeeper获得代理列表(引导服务器信息包括主机和端口)。
在springboot和springkafka中有没有一种方法可以从zookeeper中检索代理列表并在我的服务中使用代理(aka bootstrap server)列表?
1条答案
按热度按时间yvgpqqbh1#
Spring 代表
kafka-clients
所有连接;很长一段时间以来,Kafka的客户不再与zookeeper联系,只与经纪人联系。spring中没有内置的支持来查询zookeeper以确定代理列表。
此外,在未来的Kafka版本中,Zookeeper将完全消失;见kip-500。