2016-10-20 276 views
0

使用新消費者API時是否可以刪除消費者偏移量?使用新消費者API刪除kafka消費者偏移量

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.

回答

0

的唯一方法:手動發送到__consumer_offsets主題消息以正確的密鑰和有效載荷= NULL。

卡夫卡會在一段時間內刪除所有消費者數據(由offsets.retention.minutes設置)。默認是24小時。