使用新消费者API删除kafka消费者偏移量

Question

使用新消费者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.

Answer 1

的唯一方法：手动发送到__consumer_offsets主题消息以正确的密钥和有效载荷= NULL。

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