kafkalistener手動(dòng)提交 如何獲取kafka某一topic中最新的offset?
如何獲取kafka某一topic中最新的offset?如果您使用的是0.9或更高版本,則可以使用最新的客戶(hù)機(jī)消費(fèi)者.seekToEnd() / 消費(fèi)者地位()可用于獲取最新偏移量:${日志.dirs
如何獲取kafka某一topic中最新的offset?
如果您使用的是0.9或更高版本,則可以使用最新的客戶(hù)機(jī)消費(fèi)者.seekToEnd() / 消費(fèi)者地位()可用于獲取最新偏移量:${日志.dirs}/復(fù)制偏移量檢查點(diǎn)
我來(lái)這里玩的時(shí)候,我什么都沒(méi)做。我開(kāi)始在各種網(wǎng)絡(luò)上尋找技術(shù)信息,然后我把重點(diǎn)放在標(biāo)題上。從尋找信息到交朋友。因?yàn)槲矣X(jué)得事情落后于時(shí)代,有人認(rèn)為,是因?yàn)樽约核讲桓?。只是在心里想,無(wú)法實(shí)現(xiàn)現(xiàn)實(shí)
!