主題的管理

主題的管理包括創建主題、查看主題信息、修改主題和刪除主題等操作。可以通過Kafka提供的kafka-topics.sh 腳本來執行這些操作，這個腳本位于$KAFKA_HOME/bin/ 目錄下，其核心代碼僅有一行，具體如下：
exec $(dirname $0)/kafka-run-class.sh kafka.admin.TopicCommand "$@"
可以看到其實質上是調用了kafka.admin.TopicCommand 類來執行主題管理的操作。

創建主題

命令行創建主題

可以通過kafka-topics.sh 腳本來創建主題。示例如下：
bin/kafka-topics.sh --zookeeper localhost:2181/kafka --create --topic mytopic --partitions 4 --replication-factor 2
輸出：
Created topic ”mytopic”

主題，分區，副本，日志的關系

主題和分區都是提供給上層用戶的抽象， 而在副本層面或更加確切地說是Log 面才有實際物理上的存在。同一個分區中的多個副本必須分布在不同的broker 中，這樣才能提供有效的數據冗余。

主題，分區，副本，日志的關系

Zookeeper數據

?

KafkaAdminClient

分區的管理

分區數的選擇

?

總結

以上是生活随笔為你收集整理的深入理解Kafka（4）-主题与分区的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。