5.7. トピックの作成

トピックの作成

1. kafka-topics.sh ユーティリティーを使用してトピックを作成し、--zookeeper オプションで 次 の ZooKeeper URL を指定します。--create オプション: 作成される新しいトピック。--topic オプション: トピック名。--partitions オプション: パーティション数。--replication-factor オプション: レプリケーション係数。

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

   bin/kafka-topics.sh --zookeeper <ZooKeeperAddress> --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 --zookeeper zoo1.my-domain.com:2181 --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 --zookeeper <ZooKeeperAddress> --describe --topic <TopicName>

   Copy to Clipboard Toggle word wrap

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

   bin/kafka-topics.sh --zookeeper zoo1.my-domain.com:2181 --describe --topic mytopic

   Copy to Clipboard Toggle word wrap