引导服务器与kafka中的zookeeper？

作者: 故人
发布时间: 2024-11-26 12:22:21 (2月前)
转自：

4 条回复

0#
回复此人
你瞎啊！撞我心了 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 在当前使用--zookeeper或--bootstrap-server参数的kafka-consumer工具中，区分使用旧消费者和新消费者。旧的消费者需要Zookeeper连接，因为偏移量保存在那里。新的消费者不再需要Zookeeper，因为偏移量被保存到Kafka经纪人的__consumer_offset主题中。今天不鼓励使用旧的消费者，因此对于新的应用程序，最好使用新的实现。 </p> </DIV>

编辑
1#
回复此人
Coolkid | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> Kafka消费者需要将偏移量提交给kafka并从kafka获取偏移量，因为kafka将偏移量存储从zookeeper转移到kafka经纪人，kafka-consumer不需要直接与zookeeper通信，因此新的kafka消费者不需要配置动物园管理员。但是kafka使用者总是需要连接到kafka代理（集群）来将请求发送到服务器，bootstrap-server只是这个集群的一些代理，使用它，消费者可以找到所有的代理。 </p> </DIV>

编辑
2#
回复此人
张三岁 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <UL> <LI> 在旧版Kafka（v 0.9.0）中，Kafka用于在Kafka服务器上存储数据，所有与偏移相关的信息（如当前分区偏移）都存储在zookeeper中。因此，对于消费者来说，运行它需要数据和元数据。因此，为了获取元数据，它必须调用zookeeper。这就是它使用zookeeper和Kafka的原因。前 <a href="https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example" rel="noreferrer"> 旧消费者代码 </A> </LI> <LI> 在新版本的卡夫卡即（v 0.10.0 - 以上）。它将所有主题元数据信息（总分区及其当前偏移量）存储在同一Kafka服务器上的__consumer_offset主题中。所以现在只有卡夫卡经纪人才需要与zookeeper和消费者从kafkabroker本身获取所有数据和元数据，因此它现在不再需要与zookeeper通信。 </LI> </UL> <P> 当前架构的优势： 1.同一地点的数据和元数据很容易管理。 </p> </DIV>

编辑

登录后才能参与评论