如何獲取kafka某一topic中最新的offset？如果您是0.9或更高版本，您可以使用最新的消費(fèi)者客戶端消費(fèi)者.seekToEnd() / 消費(fèi)者地位（）可用于獲取最新偏移量：${日志.dirs

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

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

classlogclient（object）：defuuuuu初始化（self，kafkahost，kafkaport）：self.kafkahostself=卡夫卡霍斯特.kafkaport=kafkaportdeffixlen（self，s，l）：s=s[0:8]工作節(jié)點(diǎn)s[8:]fixed=s“”*（l-len（s））returnfixeddefsendlog（self，topic，filename）：嘗試：client=kafkaclient( 卡夫卡霍斯特， 卡夫卡波特)producer=simpleproducer（客戶端，主題）f=open（文件名，“rb”）fname=路徑.basename（f.name）ftext=f.read（）生產(chǎn)者發(fā)送消息（自定（fname，30）ftext）f.關(guān)閉（）客戶端.close（）打印“卡夫卡森”filenameexception，ex:printex

在使用Kafka的過程中，主題的數(shù)量沒有限制，但是主題的分區(qū)總數(shù)有一個(gè)上限。當(dāng)達(dá)到上限時(shí)，用戶將無法繼續(xù)創(chuàng)建主題。