0
私たちのセットアップには、Zookeeperと複数の独立したKafkaブローカーがあります。特定のブローカーに関するトピックをプログラムで作成する必要があります。Zookeeper、複数のKafkaブローカー - 特定のブローカーでプログラム的にトピックを作成する方法？
私たちはAdminUtilsを使用してトピックを作成しています（すでに最初に存在するかどうかを確認した上で）。この呼び出しは次のようになります。
AdminUtils.createTopic(zkUtils, topic, partitions = 1, replicationFactor = 1, properties)
「プロパティ」にはcleanup.policyのエントリが1つしかありません。この呼び出しの問題は、Zookeeperが1つとランダムを選ぶように、トピックを作成するKafkaブローカーを指定する場所がどこにもないことです。
トピックを作成するブローカーを指定する方法を教えてください。
トピックは、特定のブローカーに作成することができるというような概念はありません。また、PropertiesクラスはHashtableを継承しています.Hashtableは、複数のKVペアをユーザーが接続できる 'setProperty'メソッドを提供します。 – amethystic
別の言い方をすれば、私が分離されたブローカーを欲しければ、それらはすべて飼育係の別のインスタンスに関連付ける必要がありますか？それは正しいとは言えません... –