我正在使用pykafka python库api创建一个kafka主题，使用以下代码。
from pykafka import KafkaClient
client = KafkaClient(hosts="127.0.0.1:9092")
topic = client.topics[topic_name]
producer = topic.get_producer(sync=True)
producer.produce('message'))这里创建的主题默认只有一个分区。如何使用类似pykafka的方法为主题分配多个分区 topic.number_of_partitons=3 ?
1条答案
按热度按时间kknvjkwl1#
你注意到了皮Kafka对主题自动生成的支持。访问通过
client.topicsdict，这个主题是用代理配置中定义的默认设置自动创建的。pykafka还支持cli与kafka 0.10.1中的主题创建和删除api的集成。有关如何使用它的信息，请参阅源代码。举个例子：