通常需要?jiǎng)?chuàng)建自定義分區(qū)的topic 可以使用以下方法創(chuàng)建名稱為test，12個(gè)分區(qū)3份副本的topic

成都創(chuàng)新互聯(lián)公司是一家專業(yè)提供青海企業(yè)網(wǎng)站建設(shè),專注與成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)、HTML5、小程序制作等業(yè)務(wù)。10年已為青海眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)絡(luò)公司優(yōu)惠進(jìn)行中。

from kafka.admin import KafkaAdminClient, NewTopic
c = KafkaAdminClient(bootstrap_servers="localhost:9092")
topic_list = []
topic_list.append(NewTopic(name="test", num_partitions=12, replication_factor=3))
c.create_topics(new_topics=topic_list, validate_only=False)