我已经安装了Apache,并且确认了生产者和消费者在本地主机上工作。
如何设置Kafka以便:
我注意到了以下一行:zookeeper.connect=localhost:2181 in server.properties,用于启动kafka服务器。如果这是该设置,则是它所侦听的地址的设置,还是它是否指定服务器的地址/端口在网络上?
发布于 2015-12-28 13:27:56
卡夫卡内部使用动物园管理员来协调集群(领袖选举)。在0.8之前的卡夫卡版本中,ZK是消费者补偿的独家存储(到目前为止消费的产品),但从0.8.1开始,我认为您可以选择是在ZK中存储偏移量,还是在一个名为__consumer_offsets的特殊卡夫卡主题中存储偏移量。
您感兴趣的是卡夫卡向客户公开的advertised.host.name和advertised.port设置(或者如您所说的“它所听的地址”)。
发布于 2015-12-28 13:14:21
这是卡夫卡连接到的动物园管理员服务器的名字。代理配置的文档可以在这里找到http://kafka.apache.org/documentation.html#brokerconfigs。
https://stackoverflow.com/questions/34493553
复制相似问题