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