一般的な Kafka コマンドの使用方法を学び、さまざまなシナリオに柔軟に対応します。

#Kafka 学習の要点: 一般的なコマンドをマスターし、さまざまなシナリオに簡単に対処する

1. トピックを作成する

bin/kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2

2. トピックのリスト

bin/kafka-topics.sh --list

3. トピックの詳細の表示

bin/kafka-topics.sh --describe --topic my-topic

4. 制作メッセージ

bin/kafka-console-producer.sh --topic my-topic --message "Hello, Kafka!"

5. メッセージの消費

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

6. パーティション数の変更

bin/kafka-topics.sh --alter --topic my-topic --partitions 5

7.コピー数の変更

bin/kafka-topics.sh --alter --topic my-topic --replication-factor 3

8. トピックの削除

bin/kafka-topics.sh --delete --topic my-topic

9. コンシューマ グループ

bin/kafka-consumer-groups.sh --create --group my-group

# の作成# #10. コンシューマ グループの一覧表示

bin/kafka-consumer-groups.sh --list

11. コンシューマ グループの詳細の表示

bin/kafka-consumer-groups.sh --describe --group my-group

12. コンシューマ グループへのコンシューマの追加

bin/kafka-consumer-groups.sh --join --group my-group --topic my-topic

13. コンシューマ グループからコンシューマを削除します

bin/kafka-consumer-groups.sh --leave --group my-group --topic my-topic

14. コンシューマ グループを削除します

bin/kafka-consumer-groups.sh --delete --group my-group

15. Topic

bin/kafka-run-class kafka.tools.GetOffsetShell --topic my-topic --group my-group

のオフセットを取得します。16. Topic

bin/kafka-run-class kafka.tools.OffsetResetTool --topic my-topic --group my-group --to-earliest

のオフセットを設定します。 17. Kafka クラスターを監視します

bin/kafka-server-start.sh --daemon --console

18. Kafka クラスターをシャットダウンします

bin/kafka-server-stop.sh

19. Kafka クラスターを診断します

bin/kafka-run-class kafka.tools.JmxTool --query "kafka.server:type=*,name=*,clientId=*"

20. Kafka クラスターの構成のエクスポート

bin/kafka-run-class kafka.tools.DumpLogSegments --print-data --source /tmp/kafka-logs

21. Kafka クラスターの構成のインポート

bin/kafka-run-class kafka.tools.LoadLogSegments --source /tmp/kafka-logs

22. Kafka クラスターのアップグレード

bin/kafka-upgrade-kafka.sh --target-version 3.0.0

23. Kafka クラスターをダウングレードします

bin/kafka-downgrade-kafka.sh --target-version 2.8.0

以上が一般的な Kafka コマンドの使用方法を学び、さまざまなシナリオに柔軟に対応します。の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。