kafka查看topic数据量 怎样查看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（）producer.send消息(自定（fname，30）ftext）f.关闭（）客户端.close（）打印“卡夫卡森”FileNameException，例如：printex