我已经设置了Apache Kafka并确认 生产环境 者和消费者在localhost上工作 .
如何设置Kafka以便:
多个 生产环境 者将消息提供给网络计算机上的代理
网络上的许多消费者可以使用来自代理的消息
我注意到以下行: zookeeper.connect=localhost:2181 在 server.properties 中用于启动kafka服务器 . 如果这是设置,是它侦听的地址的设置,还是指定服务器的地址/端口在网络上?
zookeeper.connect=localhost:2181
server.properties
动物园管理员在Kafka内部用于协调集群(领导者选举) . 在0.8之前的Kafka版本中,ZK是消费者抵消的唯一商店(到目前为止消费的是什么),但是从0.8.1开始,我认为,您可以选择是在ZK中存储偏移还是在名为 __consumer_offsets 的特殊Kafka主题中存储偏移 .
__consumer_offsets
您感兴趣的是Kafka向客户公开的 advertised.host.name 和 advertised.port 设置(或"what addresses it listens to",如您所说) .
advertised.host.name
advertised.port
它是Kafka连接到的zookeeper服务器的名称 . 可以在此处找到Broker配置的文档http://kafka.apache.org/documentation.html#brokerconfigs
2 回答
动物园管理员在Kafka内部用于协调集群(领导者选举) . 在0.8之前的Kafka版本中,ZK是消费者抵消的唯一商店(到目前为止消费的是什么),但是从0.8.1开始,我认为,您可以选择是在ZK中存储偏移还是在名为
__consumer_offsets
的特殊Kafka主题中存储偏移 .您感兴趣的是Kafka向客户公开的
advertised.host.name
和advertised.port
设置(或"what addresses it listens to",如您所说) .它是Kafka连接到的zookeeper服务器的名称 . 可以在此处找到Broker配置的文档http://kafka.apache.org/documentation.html#brokerconfigs