kafka查看topic数据量 怎样查看kafka topic的分组?
浏览量:2045
时间:2021-03-15 09:45:55
作者:admin
怎样查看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
kafka查看topic数据量 kafka topic数量上限 kafka查看指定topic信息
版权声明:本文内容由互联网用户自发贡献,本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。