我已经安装了Apache Kafka,并确认生产者和消费者在本地主机上工作。
如何设置Kafka以便:
- 多个生产者将消息输入网络计算机上的代理
- 网络上的许多消费者可以使用来自代理的消息
我注意到以下行:server.properties
中的zookeeper.connect=localhost:2181
,用于启动kafka服务器。如果是这样的设置,它是监听什么地址的设置,还是指定服务器的地址/端口在网络上?
动物园管理员由Kafka在内部用于协调集群(领导人选举)。在0.8之前的Kafka版本中,ZK是消费者补偿(到目前为止消费的东西)的专属存储区,但从0.8.1开始,我认为你可以选择是将补偿存储在ZK中,还是存储在一个名为__consumer_offsets
的特殊Kafka主题中。
您感兴趣的是Kafka向客户端公开的advertised.host.name
和advertised.port
设置(或者您所说的"它监听的地址")。
这是Kafka连接到的zookeeper服务器的名称。Broker配置的文档可以在这里找到http://kafka.apache.org/documentation.html#brokerconfigs