新しいコンシューマAPIを使用してカフカコンシューマオフセットを削除する

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

唯一の方法：手動で正しいキー及びペイロード= NULLで__consumer_offsetsトピックメッセージを送ります。

カフカは、しばらくの間にすべてのコンシューマデータを削除します（オフセット。削除回数。分）。デフォルトでは24時間です。