學會使用Kafka常用指令，靈活應對各種場景的學習必備

學習Kafka必備：掌握常用指令，輕鬆應付各種場景

##1. 建立Topic

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

2. 列出Topic

bin/kafka-topics.sh --list

#3. 查看Topic詳細資料

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. 刪除Topic

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中文網其他相關文章！