如何在本地网络上设置/连接分布式Kafka代理、生产者和消费者



我已经安装了Apache Kafka,并确认生产者和消费者在本地主机上工作。

如何设置Kafka以便:

  1. 多个生产者将消息输入网络计算机上的代理
  2. 网络上的许多消费者可以使用来自代理的消息

我注意到以下行:server.properties中的zookeeper.connect=localhost:2181,用于启动kafka服务器。如果是这样的设置,它是监听什么地址的设置,还是指定服务器的地址/端口在网络上?

动物园管理员由Kafka在内部用于协调集群(领导人选举)。在0.8之前的Kafka版本中,ZK是消费者补偿(到目前为止消费的东西)的专属存储区,但从0.8.1开始,我认为你可以选择是将补偿存储在ZK中,还是存储在一个名为__consumer_offsets的特殊Kafka主题中。

您感兴趣的是Kafka向客户端公开的advertised.host.nameadvertised.port设置(或者您所说的"它监听的地址")。

这是Kafka连接到的zookeeper服务器的名称。Broker配置的文档可以在这里找到http://kafka.apache.org/documentation.html#brokerconfigs

最新更新