pykafkaを使用して Kafka でプログラムでトピックを作成できるようにしたいと考えています。TopicDict にアクセスすると、トピックが存在しない場合にトピックが自動的に作成されることはわかっていますが、それを使用してパーティション/レプリカの数を制御する方法がわかりません。また、Kafka がダウンすると無限ループになってしまうという厄介なバグがあります。基本的に私は次のようなことをしたい：
create_topic('mytopic', partitions=2, replicas=3)