nik*_*kel 3 apache-kafka kafka-producer-api apache-zookeeper
卡夫卡生产者需要一个卡夫卡经纪人的引导清单才能工作。根据此说明,它需要能够连接到其中一个代理,然后获取有关集群中所有活动代理的元数据。
现在,所有代理都已经在Zookeeper中注册,并且Kafka使用者连接到ZK,该ZK处理从哪个Broker哪个分区读取数据。ZK已经掌握了所有信息后,为什么生产者也不能连接到ZK?
我看到有一些SO问题,但它们似乎可以解释为什么消费者需要ZK,而不是为什么Producer需要经纪人引导列表而不是ZK?
生产者和消费者过去都曾与Zookeeper进行连接以进行协调,但现在已经从此演变了。借助Kafka 0.9中的新消费者API,所有客户都不再需要了解Zookeeper,这似乎是Kafka客户的未来。除了摆脱对ZK的依赖关系和不稳定的连接库之外,它还使客户端协议的演进变得更加容易,因为它现在完全由Kafka进行管理。
目前,两个消费者客户端都可以在Kafka 0.9中使用,但是您应该准备好在将来的版本中的某个时候不赞成使用ZK连接的消费者客户端。
| 归档时间: |
|
| 查看次数: |
2727 次 |
| 最近记录: |