5.7. トピックの作成

トピックの作成

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