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>

     Copy to Clipboard Toggle word wrap

     という名前のトピックを作成するコマンドの例 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

     Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap