2016 - 2024

感恩一路有你

kafka topic数量上限 kafka对topic有限制吗?

浏览量:1983 时间:2021-03-10 16:38:13 作者:admin

kafka对topic有限制吗?

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

如何获取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,例如:printex

kafka topic数量上限 kafka可以建立多少个topic kafka动态创建topic

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