问用新的消费api删除kafka消费者补偿
EN

Stack Overflow用户

提问于 2016-10-20 09:30:44

回答 1查看 669关注 0票数 0

在使用新的使用者API时，是否可以删除使用者偏移量？

bin/kafka-consumer-groups.sh输出：

WARNING: Group deletion only works for old ZK-based consumer groups, and one has to use it carefully to only delete groups that are not active.

发布于 2016-10-20 09:39:10

唯一的方法:用正确的键和payload=null手动发送到payload=null主题消息。

卡夫卡将在一段时间内删除所有消费者数据(由offsets.retention.minutes).设置)默认是24小时。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/40150576

复制

相似问题

问用新的消费api删除kafka消费者补偿EN