目錄
一、主題topic指令行操作
1.檢視操作主題的指令參數
2.連接配接kafka位址,建立名為kaf的主題,指定分區和副本數量
3.檢視所有主題的名稱
4.檢視主題的詳細資訊
5.修改主題(修改分區數)
二、生産者指令行操作
1.檢視操作生産者的指令參數:kafka-console-produce.sh
2.生産一個資料,放到topic kaf中
3.消費者使用資料 slave2 slave3都可
一、主題topic指令行操作
1.檢視操作主題的指令參數:kafka-topic.sh
參數 | 說明 |
--bootstrap-server<String: server to connect to> | 設定連接配接kafka的主機名和端口号 |
--topic <String: topic> | 設定操作主題的名稱 |
--create | 建立主題 |
--delete | 删除主題 |
--alter | 修改主題(修改主題的分區數) |
--list | 顯示所有主題 |
--describe | 顯示指定主題的詳細資訊 |
--partitions <Integer: # of partitions> | 設定主題的分區數 |
partitions <Integer: # of partitions> | 設定分區的副本數量 |
2.連接配接kafka位址,建立名為kaf的主題,指定分區和副本數量:--bootstrap-server slave2:9092
3.檢視所有主題的名稱
4.檢視主題的詳細資訊
5.修改主題(修改分區數),隻能改更大的,分區數隻能增加
二、生産者指令行操作
1.檢視操作生産者的指令參數:kafka-console-produce.sh
2.生産一個資料,放到topic kaf中,
3.消費者使用資料 slave2 slave3都可
slave1生産什麼slave3消費什麼
但是消費者進入前的資料并沒有拉取到,應該怎麼樣才可以把之前的資料拉取到
在slave3中使用該指令即可