java - 从 bootstrap server 和 zookeeper 消费消息有什么区别?

标签 java apache-kafka apache-zookeeper

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

最佳答案

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

您可能应该使用新的,这意味着您只需要配置 bootstrap-servers(您正在使用的 Kafka 代理的 url)而无需定义 zookeeper 连接 url。

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

关于java - 从 bootstrap server 和 zookeeper 消费消息有什么区别?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39280511/

相关文章:

java - Kafka - 使用高级消费者实现延迟队列

apache-kafka - Kafka + Zookeeper : Connection to node -1 could not be established. Broker 可能不可用

apache-kafka - 为什么Kafka是基于拉而不是基于推的?

scala - 无法在本地主机中使用 Solr 连接到 ZooKeeper

apache-zookeeper - 无法启动动物园管理员

java - 创建并覆盖一个形状以适合 JPanel?

java - JavaPlot 中的 "With lines"?

java - JAX-RS + JAXB (XML) -- 如何将单个字节作为十六进制传递?

java - JFrame 在应该关闭的时候没有关闭

c - librdkafka 消费者未收到来自代理的消息