JAVA面試如何保證消息不被重復(fù)消費？如何保證消息消費的冪等性？我沒事，來這里玩，開始在各種網(wǎng)絡(luò)上尋找技術(shù)信息，之后以“頭條”為主。從尋找信息到交朋友。因為我覺得事情落后于時代，有人認為，是因為自己水

JAVA面試如何保證消息不被重復(fù)消費？如何保證消息消費的冪等性？

我沒事，來這里玩，開始在各種網(wǎng)絡(luò)上尋找技術(shù)信息，之后以“頭條”為主。從尋找信息到交朋友。因為我覺得事情落后于時代，有人認為，是因為自己水平不高。只是在心里想，無法實現(xiàn)現(xiàn)實

如何獲取kafka某一topic中最新的offset？

如果您使用的是0.9或更高版本，則可以使用最新的客戶機消費者.seekToEnd() / 消費者地位（）可用于獲取最新偏移量：${日志.dirs}/復(fù)制偏移量檢查點

查看文檔https://pykafka.readthedocs.io/en/latest/index.html