我已经安装了apachekafka,并确认生产者和消费者在localhost上工作。
如何设置Kafka以便:
多个生产者将消息馈送到网络计算机上的代理中
网络上的许多消费者可以使用来自代理的消息
我注意到下面这句话: zookeeper.connect=localhost:2181
在 server.properties
用于启动Kafka服务器。如果是这样的设置,那么它是监听什么地址的设置,还是指定服务器的地址/端口在网络上?
我已经安装了apachekafka,并确认生产者和消费者在localhost上工作。
如何设置Kafka以便:
多个生产者将消息馈送到网络计算机上的代理中
网络上的许多消费者可以使用来自代理的消息
我注意到下面这句话: zookeeper.connect=localhost:2181
在 server.properties
用于启动Kafka服务器。如果是这样的设置,那么它是监听什么地址的设置,还是指定服务器的地址/端口在网络上?
2条答案
按热度按时间2ledvvac1#
Kafka在内部使用zookeeper来协调集群(领导人选举)。在0.8之前的kafka版本中,zk是消费者补偿(到目前为止消费了什么)的专用存储,但是从0.8.1开始,我认为,您可以选择是在zk中存储补偿,还是在一个名为
__consumer_offsets
.你感兴趣的是
advertised.host.name
以及advertised.port
Kafka向客户机公开的设置(或者你所说的“它监听的地址”)。pepwfjgg2#
它是kafka连接到的zookeeper服务器的名称。代理配置的文档可以在这里找到http://kafka.apache.org/documentation.html#brokerconfigs