天天看點

簡單的kafka指令行操作

目錄

一、主題topic指令行操作

1.檢視操作主題的指令參數

2.連接配接kafka位址,建立名為kaf的主題,指定分區和副本數量

3.檢視所有主題的名稱

4.檢視主題的詳細資訊

5.修改主題(修改分區數)

二、生産者指令行操作

1.檢視操作生産者的指令參數:kafka-console-produce.sh

2.生産一個資料,放到topic kaf中

3.消費者使用資料 slave2 slave3都可

一、主題topic指令行操作

1.檢視操作主題的指令參數:kafka-topic.sh

簡單的kafka指令行操作
簡單的kafka指令行操作
參數   說明
--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

簡單的kafka指令行操作

3.檢視所有主題的名稱

簡單的kafka指令行操作

4.檢視主題的詳細資訊

簡單的kafka指令行操作

5.修改主題(修改分區數),隻能改更大的,分區數隻能增加

簡單的kafka指令行操作
簡單的kafka指令行操作

二、生産者指令行操作

1.檢視操作生産者的指令參數:kafka-console-produce.sh

簡單的kafka指令行操作

2.生産一個資料,放到topic kaf中,

簡單的kafka指令行操作

3.消費者使用資料 slave2 slave3都可

簡單的kafka指令行操作
簡單的kafka指令行操作

 slave1生産什麼slave3消費什麼

簡單的kafka指令行操作
簡單的kafka指令行操作

 但是消費者進入前的資料并沒有拉取到,應該怎麼樣才可以把之前的資料拉取到

 在slave3中使用該指令即可

簡單的kafka指令行操作

繼續閱讀