一、主題說明
二、生產者消費者角色說明
1、生產消費者
從生產者的角度來說,他所操作的單元,一般情況下屬於主題為單位
從消費者的角度來說,他所操作的單元,一般情況下屬於主題為單位
生產者、消費者可以以主題更細單位來操作--->(分區),也是消息的分類
從kafka的角度來說,沒有限制生產者也沒有限制消費者
生產者與消費者在處理數據的時候,必須要知道要操作的主題是哪一個
三、創建屬於我們自己的主題?
1、一個broker服務下,是否可以創建多個分區?
可以,broker數與分區數沒有關系
2、一個broker服務下,是否可以創建多個副本因子
不可以。但報錯
replication factor: 3 larger than available brokers: 創建主題時,副本因子應該小於等於可用的broker數 kafka-topics.sh --create --topic mytopic5 --zookeeper localhost:2181 --partitions 3 --replication-factor 1 --config max.message.bytes=6400 --config flush.messages=1
3、查看當前有哪些主題
kafka-topics.sh --describe --zookeeper localhost:2181 在kafka中每一個分區會有一個編號:從0開始
4、更多關於主題的操作的命令詳見