怎樣查看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]工作節(jié)點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.關閉（）客戶端.close（）print“kafkasent”Filenameexception，ex:printex

怎么查詢kafka的日志路徑？

Kafka的分布式單元是分區(qū)。Kafka保證分區(qū)中的數(shù)據(jù)是有序的，但是分區(qū)之間的數(shù)據(jù)不能保證順序。多分區(qū)的特性使Kafka具有一定的分布式消息傳遞能力。

在業(yè)務中，我們需要將需要嚴格排序的數(shù)據(jù)放在一個分區(qū)上，同時，我們需要將可以分發(fā)到其他分區(qū)的消息放在一個分區(qū)上，以確保高性能。