Kafka 0.9 - java apiを使用してトピックを作成するには

Question

Kafkaに新しく追加されました。

0.9リリースでトピックを作成するためにjava-apiを使用する方法を理解するのが難しい。

このanswerは0.8です。

Clusterにはパーティション情報やトピックなどを照会する方法がありますが、どのようにしてトピックを動的に作成できるかわかりません。

Answer 1

Kafkaの場合、クラスターはトピックを作成する方法を決定します。オンザフライでトピックを作成したい場合は、クラスタでauto.create.topics.enableを使用するのが最も簡単な方法です。次に、存在しないトピックにメッセージを送信すると、クラスタはクラスタのデフォルトのパーティションとレプリケーションファクタでトピックを作成します。この機能を有効または有効にしたくない場合は、私がKafkaクライアントライブラリで知っている方法はありません。

確定したら、internals of the kafka-topics.shを調べることができます。ここで、KafkaがコアAPIを使用してトピックを作成する方法がわかります。