kafka查看消费者列表 怎样查看kafka topic的分组？

怎样查看kafka topic的分组？classlogclient（object）：定义初始化初始化（self，kafkahost，kafkaport）：self.kafkahostself=卡夫卡霍

怎样查看kafka topic的分组？

classlogclient（object）：定义初始化初始化（self，kafkahost，kafkaport）：self.kafkahostself=卡夫卡霍斯特.kafkaport=kafkaportdeffixlen（self，s，l）：s=s[0:8]工作节点s[8:]fixed=s“”*（l-len（s））返回fixedDefSendLog（self，topic，filename）：尝试：client=kafkaclient( 卡夫卡霍斯特， 卡夫卡波特)producer=simpleproducer（客户端，主题）f=open（文件名，“rb”）fname=路径.basename（f.name）ftext=f.read（）生产者发送消息（自定（fname，30）ftext）f.关闭（）客户端.close（）print “kafkasent”filenameexception，ex:printex

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

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