zookeeper和Kafka服务器重启后Kafka消费群体依然存在
我使用Zookeeper和Kafka作为使用Java的消息传递用例。我以为当您重新启动Zookeeper和Kafka服务器时，消费者组详细信息会被删除。但他们没有。zookeeper会将消费者组详细信息保存在某种文件中吗？
如果我想重置消费者组，我应该手动删除消费者组详细信息吗？
任何人都可以向我澄清这一点吗？
共有1个答案
从Kafka 0.9开始，消费者偏移量直接存储在Kafka中名为__consumer_offsets的内部主题中。
使用者偏移量在重新启动后保留，并且至少保留偏移量.retention.分钟（默认为 7 天）。
如果要重置消费者组，可以：
>
使用kafka-consumer-groups.sh工具和--reset-offset选项
使用admin client . deleteconsumergroups()完全删除使用者组
-
我是Kafka的新手，正在学习Kafka内部知识。请根据需要随时更正我的理解。。 这是我的实时场景..感谢所有的回复: 我有一个接收数据文件的实时FTP服务器…比如索赔文件。 我将把这些数据发布到一个主题中.让我们把这个主题称为claims_topic（2个分区）. 我需要订阅这个claims_topic，阅读消息并将它们写入Oracle和Postgres表。让我们将oracle表称为Otable
-
我正在使用Docker启动一个kafka代理集群（例如，5个代理，每个容器一个代理）。Kafka版本2.12-0.11.0.0，动物园管理员3.4.10。 场景： null > 在独立模式下启动Zookeeper，然后启动kafka 创建主题 null 检查邮件 消息被累犯 null null server.properties（broker.id唯一，broker_ip:broker_port对
-
在一个消费者群体中的所有消费者都失败后，kafka会将该消费者群体的补偿存储多长时间？是否有此配置变量？
-
我在使用Kafka时遇到了一些问题。非常感谢任何帮助！我在docker swell中分别有zookeeper和kafka集群3个节点。您可以在下面看到Kafka代理配置。 我的情况： < li > 20x位制片人不断向Kafka主题传达信息 < li>1x消费者读取和记录消息 < li >终止kafka节点(docker容器停止)，因此现在群集有2个Kafka代理节点(第3个节点将自动启动并加入群
-
我们希望获得Kafka消费群体指标（例如，节流和字节率）。 我们已经使用以下工具完成了此操作： Kafka消费者Java应用程序的JMX Mbean CLI实用程序： bin/kafka-consumer-groups.sh--描述--组group_name--bootstrap-serverlocalhost： port . 问题：这可以通过使用一些Java库以编程方式完成吗？ 到目前为止，我们
-
我是Kafka的初学者 1/我下载了Kafka的1.0.0版本 2/I更改了bith server.properties和zookeeper.properties中的数据目录位置属性 你能帮帮我吗？