本文介紹了如何刪除Kafka消費群(通過新的消費者API創建)？的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
我通過新的消費者接口創建了Kafka消費者
我使用的是卡夫卡2.10-0.9.0.1
我們有一個消費者組，每個組中有一個消費者實例
Kafka腳本‘kafka-Consumer-groups.sh’提供了刪除用戶的方法，但這僅適用于舊的消費群體
正在運行命令：
bin/kafka-Consumer-groups.sh
給予
–刪除：警告：組刪除僅適用于基于ZK的舊消費組，必須謹慎使用，以便僅刪除非活動的組。
所以我想問一下，有什么方法可以刪除通過新的消費者API創建的消費者組嗎？
推薦答案
新消費者不需要刪除。以下是該腳本在嘗試刪除時的輸出：
請注意，沒有必要刪除新使用者的組元數據，因為它會在最后一個成員離開時自動刪除
這是簡短的答案。更多細節：”元數據”指的是兩件事。首先，只是作為組成員資格協調器的一部分存儲的關于消費者和消費者組的信息。如果組中的所有使用者都消失，則會自動刪除。
其次，消費者組已將承諾的偏移量存儲在Kafka主題中(當使用新的消費者時。以前，這些文件通常與ZooKeeper一起存儲)。當消費者組消失時，該主題不會立即刪除。如果消費者組再次出現，它將在本主題中自動查找以前的偏移量。它可以選擇使用它們，也可以忽略它們。如果使用者組再也不出現，這些存儲的偏移量最終將被自動垃圾收集。
因此，簡而言之，在使用新的使用者時不需要刪除任何內容。
這篇關于如何刪除Kafka消費群(通過新的消費者API創建)？的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
