Kafka トピックを作成する手順: Kafka コマンドの使用

#Kafka コマンドを使用してトピックを作成する手順

1. ZooKeeper と Kafka サービスを開始する

zookeeper-server-start.sh config/zookeeper.properties
kafka-server-start.sh config/server.properties

#トピックの作成
2. ##

   kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

#トピックの表示

##

kafka-topics.sh --list

3. トピックにメッセージを送信

#

kafka-console-producer.sh --topic my-topic --message "Hello, world!"

4. #トピックからのメッセージを消費
#

kafka-console-consumer.sh --topic my-topic --from-beginning

具体的なコード例

5. # 启动ZooKeeper服务
   zookeeper-server-start.sh config/zookeeper.properties
   
   # 启动Kafka服务
   kafka-server-start.sh config/server.properties
   
   # 创建主题
   kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1
   
   # 查看主题
   kafka-topics.sh --list
   
   # 向主题发送消息
   kafka-console-producer.sh --topic my-topic --message "Hello, world!"
   
   # 从主题消费消息
   kafka-console-consumer.sh --topic my-topic --from-beginning

Note

トピックを作成するときは、トピックの名前、パーティションの数、そしてレプリカの数。

パーティションの数によって、トピックが同時に処理できるメッセージの数が決まります。 コピー数によって、トピックのデータのコピー数が決まります。

メッセージをトピックに送信するときは、メッセージのキーと値を指定する必要があります。
• トピックからメッセージを消費する場合、コンシューマ グループを指定できます。コンシューマ グループ内のコンシューマは、トピック内のメッセージを共同で消費します。

以上がKafka トピックを作成する手順: Kafka コマンドの使用の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。