当前位置: 首页 > 知识库问答 >
问题:

Kafka--非基于动物园管理员的消费者与基于动物园管理员的消费者

淳于开畅
2023-03-14

注意:这将只显示有关使用Java消费者API的消费者(非基于ZooKeeper的消费者)的信息。

此工具还适用于基于ZooKeeper的使用者:

bin/kafka-consumer-groups.sh--zookeeper localhost:2181--description--group my-group

    null

PS:这似乎没有出现在2.5文档中

共有1个答案

狄鸿禧
2023-03-14

在Kafaka0.9之前,消费者使用Zookeeper进行协调。从那以后,消费者现在只连接到Kafaka。

因此,kafka-consumer-groups.sh支持显示“基于zookeeper的”(即旧的消费者)组的详细信息。

“老消费者”在Kafaka0.11中被弃用,最终在2.1.0中被移除。还更新了kafka-consumer-groups.sh以删除对它的任何提及。

 类似资料:
  • 我在这里指的是一篇帖子:在ApacheKafka多节点集群中连接Zookeeper 这里提到,从KafkaV9版开始,制作人和消费者不必使用zookeeper。连接属性和引导。服务器足以生成/使用数据。 我的POM。xml在消费者端看起来是这样的: 在没有zookeeper的情况下,我在消费者方面遇到了以下问题。连接属性。有人在没有zookeeper connect属性的情况下让消费者部分工作吗?

  • 我将Kafka2.9.2-0.8.1.1与zookeeper 3.4.6一起使用。 是否有一个实用程序可以自动从Zookeeper中删除一个消费者组?或者我可以删除zookeeper中/consumers/[group_id]下的所有内容吗?如果是后者,我还缺少什么吗&这可以用一个动态系统来完成吗? 更新:从kafka 2.3.0版本开始,有一个新的实用程序: 相关文档:http://kafka.

  • 分布式 Apache HBase 安装依赖于正在运行的 ZooKeeper 集群。所有参与节点和客户端都需要能够访问正在运行的 ZooKeeper 集合。 Apache HBase 默认为您管理 ZooKeeper“集群”。它将启动和停止 ZooKeeper 集合作为 HBase 启动/停止过程的一部分。您还可以独立于 HBase 管理 ZooKeeper 集合,只需将 HBase 指向它应该使用

  • 我正在为Storm开发代码,这是开发人员的一个示例。我的问题是,当您从IDE Eclipse运行此代码时,不会建立Storm和ZooKeer之间的连接。ZooKeer在2181中运行,也设置在storm.yaml. 我的例外是: 有什么想法或程序要执行吗?是否从配置代码中传递?和我一样?

  • 假设我有 3 台 Kafka 服务器。服务器 1 zoopkeeper1 服务器 2 zoopkeeper2 服务器 3 zoopkeeper3 在集群配置中,zoopkeepers 会发生什么?它们是为每个服务器单独维护的,还是会在群集配置中同步其数据?

  • 在Zookeeper和代理身份验证上启用SASL时,我面临以下错误。 以下配置在JAAS文件中给出,该文件作为KAFKA_OPTS传递,将其作为JVM参数:- Kafka经纪人的服务器。属性设置了以下额外字段:- Zookeeper属性如下所示: