【问题标题】:What is difference between consuming messages from bootstrap server and zookeeper?从引导服务器和 Zookeeper 消费消息有什么区别?
【发布时间】:2017-01-09 20:50:14
【问题描述】:

我是 Apache kafka 的初学者。我对引导服务器和动物园管理员感到困惑。那么请解释一下kafka中的引导服务器是什么以及它与zookeeper有何不同?消费来自 bootstrap server 或 zookeeper 的消息是什么意思。

【问题讨论】:

    标签: java apache-kafka apache-zookeeper


    【解决方案1】:

    你很困惑,因为 Kafka 有两个消费者,新的和旧的。

    您可能应该使用新的,这意味着您只需要配置引导服务器(您从中消费的 Kafka 代理的 url),而无需定义 zookeeper 连接 url。

    如果你使用旧的消费者,它需要 Zookeeper 来维护它的状态(从每个分区读取的最后一条消息)——所以你给它一个 zookeeper URL(因为它无论如何都需要 zookeeper)并且它使用 Zookeeper 来查找 Kafka 代理。

    【讨论】:

    • 那么,如何在新的消费者中获取 kafka 状态,比如特定的代理有多少个主题和分区,每个消费者组每个主题的偏移量?
    • 这里有常用的命令行工具——kafka-topics、kafka-consumer-groups。
    猜你喜欢
    • 2011-08-05
    • 2018-08-29
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2015-03-22
    • 1970-01-01
    • 2018-10-23
    相关资源
    最近更新 更多