用户控制台中的Bootstrap-服务器与zookeeper参数

Question

我读过消费控制台中的线程boostrap-server vs zookeeper，但我不清楚这一点。

我的疑问是，假设我们有zookeeper在localhost:2181上运行，三个代理服务器在localhost:9092、localhost:9093、localhost:9094上运行，我们有一个主题my_topic与分区3和replication1，主题由代理共享，因为它有三个分区。

在Apache-Kafka的新版本中，当我们运行consumer console时，我们需要传递--bootstrap-server localhost:9092，这是代理地址之一，但在早期版本中，我们传递的是zookeeper地址。

所以当我们运行consumer从主题my_topic中获取消息时，我们传递的参数--bootstrap-server localhost:9092只是代理地址之一，所以我的问题是，我们是否限制consumer只能从该代理获取消息，如果是的话，那么就让我们说明该代理是否已经关闭，那么consumer将如何从该主题读取消息。我不明白它是怎么工作的，请谁给我弄清楚。

运行使用者的旧版本命令(<1.0)
bin/kafka-console-consumer.sh--zookeeper localhost:2181--from-beginent-topic my_topic
运行使用者的新版本命令(>=1.0)
bin/kafka-console-consumer.sh--bootstrap-server localhost:9092--from-beginent-topic my_topic

Answer 1

在以前的Kafka版本(0.9.0之前）中，使用者需要连接到Zookeeper以提交偏移量和获取主题元数据。从0.9.0开始，consumer offeset保存在Kafka主题(__consumer_offset)中，不再需要连接到Zookeeper。

您在--bootstrap-server参数中指定的内容正是...说。这是一个bootstrap servers列表：它意味着使用者连接到您指定的代理，并请求关于它想要使用的主题的元数据。它不仅限于使用--bootstrap-server参数中列出的代理的消息。假设您指定“kafka1:9092”作为引导服务器（在一个集群中，如您所说，您有3个代理）。连接之后，使用者发送一个元数据请求，以获取关于“my_topic”的信息。“kafka1”服务器可以回复“我不是my_topic partition 0的leader，这里是broker，它是那个kafka2的leader”。此时，使用者连接到“kafka2”代理以开始获取消息。