kafka删除topic 如何获取kafka某一topic中最新的offset？

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

如果您是0.9或更高版本，您可以使用最新的消费者客户端消费者.seekToEnd() / 消费者地位（）可用于获取最新偏移量：${日志.dirs}/复制偏移量检查点

classlogclient（object）：defuuuuu初始化（self，kafkahost，kafkaport）：self.kafkahostself=卡夫卡霍斯特.kafkaport=kafkaportdeffixlen（self，s，l）：s=s[0:8]工作节点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（）生产者发送消息（自定（fname，30）ftext）f.关闭（）客户端.close（）打印“卡夫卡森”filenameexception，ex:printex

在使用Kafka的过程中，主题的数量没有限制，但是主题的分区总数有一个上限。当达到上限时，用户将无法继续创建主题。

kafka删除topic kafka删除积压数据 kafka生产数据命令

版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。