pyafafkaを使用してカフカトピック作成時に複数のパーティションを作成する

Question

pykafka python library apiを使用して次のコードを使用してカフカトピックを作成しています。

ここ

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')) 

トピックは私が

topic.number_of_partitons=3ようpykafkaのものを使用してトピックに複数のパーティションを割り当てることができますdefault.Howとしてのみ1パーティションで作成されましたか？

Answer 1

PyKafkaは現在、豊富なトピックの作成をサポートしていません。トピック自動作成機能を使用して、デフォルト設定のトピックを作成するだけです。カスタム設定でトピックを作成するには、Kafka CLI toolsを使用する必要があります。

PyKafkaは、独自のCLI統合のために、Kafka 0.11で新たに追加されたトピック作成および削除APIをサポートするためにplannedをサポートしています。