5.7. トピックの作成

kafka-topics.sh ツールを使用してトピックを管理できます。kafka-topics.sh AMQ Streams ディストリビューションの一部で、bin ディレクトリーにあります。

前提条件

  • AMQ Streams クラスターがインストールされ、実行されている。

トピックの作成

  1. kafka-topics.sh ユーティリティーを使用してトピックを作成し、以下を指定します。

    • --bootstrap-server オプションで、Kafka ブローカーのホストおよびポート。
    • --create オプションに作成される新しいトピック。
    • --topic オプションのトピック名。
    • --partitions オプション内のパーティション数。

    • --replication-factor オプションのトピックレプリケーション係数。

      また、--config オプションを使用して、デフォルトのトピック設定オプションの一部を上書きすることもできます。このオプションは複数回使用して、異なるオプションを上書きすることができます。 

      bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --create --topic <TopicName> --partitions <NumberOfPartitions> --replication-factor <ReplicationFactor> --config <Option1>=<Value1> --config <Option2>=<Value2>

      という名前のトピックを作成するコマンドの例 mytopic

      bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic mytopic --partitions 50 --replication-factor 3 --config cleanup.policy=compact --config min.insync.replicas=2

  2. kafka-topics.sh を使用してトピックが存在することを確認します。 

    bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --describe --topic <TopicName>

    という名前のトピックを記述するコマンドの例 mytopic

    bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic mytopic

関連情報