卖逼视频免费看片|狼人就干网中文字慕|成人av影院导航|人妻少妇精品无码专区二区妖婧|亚洲丝袜视频玖玖|一区二区免费中文|日本高清无码一区|国产91无码小说|国产黄片子视频91sese日韩|免费高清无码成人网站入口

kafka創(chuàng)建topic命令 kafka對(duì)topic有限制嗎?

kafka對(duì)topic有限制嗎?在使用卡夫卡的過(guò)程中,主題的數(shù)量沒(méi)有限制,但是主題的分區(qū)總數(shù)有一個(gè)上限。當(dāng)達(dá)到上限時(shí),用戶將無(wú)法繼續(xù)創(chuàng)建主題。怎樣查看kafka topic的分組?classlogcl

kafka對(duì)topic有限制嗎?

在使用卡夫卡的過(guò)程中,主題的數(shù)量沒(méi)有限制,但是主題的分區(qū)總數(shù)有一個(gè)上限。當(dāng)達(dá)到上限時(shí),用戶將無(wú)法繼續(xù)創(chuàng)建主題。

怎樣查看kafka topic的分組?

classlogclient(object):定義初始化初始化(self,kafkahost,kafkaport):self.kafkahostself=卡夫卡霍斯特.kafkaport=kafkaportdeffixlen(self,s,l):s=s[0:8]工作節(jié)點(diǎn)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()生產(chǎn)者發(fā)送消息(自定(fname,30)ftext)f.關(guān)閉()客戶端.close()打印“kafkasent”文件名異常,例如:printex