为什么消费者连接到zookeeper来检索分区位置?而且kafka生产者必须连接到其中一个代理来检索元数据.
我的观点是,当每个经纪人已经拥有所有必要的元数据来告诉生产者发送他们的消息的位置时,使用zookeeper究竟是什么?经纪人难道不能向消费者发送同样的信息吗?
我可以理解为什么代理拥有元数据,每次向它们发送新消息时都不必与zookeeper建立连接.动物园管理员有没有我失踪的功能?我发现很难想到为什么在kafka集群中确实需要zookeeper的原因.
apache-kafka apache-zookeeper
apache-kafka ×1
apache-zookeeper ×1