使用新的消费者 API 时如何删除属于主题 T 的消费者组 C答案

【问题标题】：how to delete a consumer group C belonging to topic T when using the new consumer API使用新的消费者 API 时如何删除属于主题 T 的消费者组 C
【发布时间】：2018-04-22 21:05:49
【问题描述】：

较新版本的apache kafka在内部存储消费者组数据，而不是使用zookeeper

这意味着命令行实用程序kafka-consumer-groups没有用，因为相关信息现在没有存储在zookeeper中

您能否建议：

使用新的消费者API时如何删除属于主题T的消费者组C

【问题讨论】：

你想用这个实现什么？如果重置偏移量 - 请参阅 stackoverflow.com/questions/42564594/… 和 cwiki.apache.org/confluence/display/KAFKA/…
@AlexOtt 如果我理解正确，我必须等待偏移量过期。我只是不想在我的 kafka 管理器管理页面中列出它
我认为 OP 正在询问如何摆脱在 Kafka 注册的消费者组（即摆脱消费者偏移主题）
@PragmaticProgrammer 确实

标签： linux apache-kafka

【解决方案1】：

请注意，只有当组元数据存储在 ZooKeeper 中时，才能删除组。当使用新的消费者 API（代理处理分区处理和重新平衡的协调）时，当该组的最后提交偏移量到期时，该组将被删除。

./kafka-consumer-groups.sh --zookeeper --delete --组

【讨论】：

【解决方案2】：

如果 24 小时内没有消费者组的成员提交偏移量（使用默认设置），它将过期并被自动删除。

或者，您可以使用 bin/kafka-consumer-groups 的新 --reset-offsets 选项重置偏移量或将它们设置为您想要的任何值

见Kafka 0.11 how to reset offsets

【讨论】：