python - pykafka を使用してトピックの特定のパーティションで公開する

Question

pykafkaトピックの特定のパーティションにメッセージを公開するにはどうすればよいですか。次のコードのテスト トピックには 4 つのパーティションがあり、各メッセージをその 1 つに書き込むつもりですが、どうやらそのようには機能していないようです。

from pykafka import KafkaClient

import logging
logging.basicConfig()

client = KafkaClient(hosts='localhost:9092')
print client.topics
topic = client.topics['test']
with topic.get_producer() as producer:
        for i in range(4):
                producer.produce('another test message ' + str(i ** 2), partition_key='{}'.format(0))