日日操夜夜添-日日操影院-日日草夜夜操-日日干干-精品一区二区三区波多野结衣-精品一区二区三区高清免费不卡

公告:魔扣目錄網(wǎng)為廣大站長(zhǎng)提供免費(fèi)收錄網(wǎng)站服務(wù),提交前請(qǐng)做好本站友鏈:【 網(wǎng)站目錄:http://www.ylptlb.cn 】, 免友鏈快審服務(wù)(50元/站),

點(diǎn)擊這里在線咨詢客服
新站提交
  • 網(wǎng)站:51998
  • 待審:31
  • 小程序:12
  • 文章:1030137
  • 會(huì)員:747

本文介紹了如何刪除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ì)大家有所幫助,

分享到:
標(biāo)簽:API Kafka 創(chuàng)建 刪除 消費(fèi)群 消費(fèi)者
用戶無(wú)頭像

網(wǎng)友整理

注冊(cè)時(shí)間:

網(wǎng)站:5 個(gè)   小程序:0 個(gè)  文章:12 篇

  • 51998

    網(wǎng)站

  • 12

    小程序

  • 1030137

    文章

  • 747

    會(huì)員

趕快注冊(cè)賬號(hào),推廣您的網(wǎng)站吧!
最新入駐小程序

數(shù)獨(dú)大挑戰(zhàn)2018-06-03

數(shù)獨(dú)一種數(shù)學(xué)游戲,玩家需要根據(jù)9

答題星2018-06-03

您可以通過答題星輕松地創(chuàng)建試卷

全階人生考試2018-06-03

各種考試題,題庫(kù),初中,高中,大學(xué)四六

運(yùn)動(dòng)步數(shù)有氧達(dá)人2018-06-03

記錄運(yùn)動(dòng)步數(shù),積累氧氣值。還可偷

每日養(yǎng)生app2018-06-03

每日養(yǎng)生,天天健康

體育訓(xùn)練成績(jī)?cè)u(píng)定2018-06-03

通用課目體育訓(xùn)練成績(jī)?cè)u(píng)定