0

背景: kafka server.properties ファイルでデフォルトのパーティション数 = 1 およびレプリケーション係数 = 3 に設定し、トピックの作成を有効にしました。Kafka クラスターは、認証と承認の両方で実行されています。作成、読み取り、書き込みの許可を 1 人のユーザーのみに与えたトピックがあり、その許可は foo のようなトピック プレフィックスに基づいています。. このユーザーには、foo で始まるトピックを作成および使用する権限があります。ここで、すべての foo を作成したいと思います。デフォルト パーティション = 3 およびレプリケーション ファクター = 6 のトピック (これは、サーバー プロパティのグローバル デフォルトとは異なります。トピックの作成は動的であり、名前は事前にわかりません。

質問: タイプ foo.* のトピックに異なるデフォルト パーティションとレプリケーション ファクターを指定することは可能ですか? そうでない場合、プロデューサーの観点からこれを達成するための最良の方法は何ですか?

私は KafkaAdmin ユーティリティを知っていますが、トピックの作成はプロデューサーで行われ、セキュリティ上の理由から、プロデューサーを実行しているユーザーに ZooKeeper に保存されているメタデータの管理者権限を与えたくありません。

ありがとう!

4

1 に答える 1