kafka在linux系統中的常用命令

2021-09-08 06:21:10 字數 1239 閱讀 9170

1,開啟zookeeper集群 startzk.sh

2,開啟kafka集群 start-kafka.sh

2,開啟kafka視覺化介面 kafka-manager : start-kafka-manager.sh 3

,生產者操作:

kafka-console-producer.sh --broker-list node1:

9092

--topic my-kafka-topic //my-kafka-topic時topic的名字

4,消費者操作:

kafka-console-consumer.sh --bootstrap-server node1:

9092

--topic my-kafka-topic

# 通過以上命令,可以看到消費者可以接收生產者傳送的訊息

# 如果需要從頭開始接收資料,需要新增--

from

-beginning引數

kafka-console-consumer.sh --bootstrap-server node01:

9092

--from

-beginning --topic my-kafka-topic

5,a.建立topic

kafka-topics.sh --create --zookeeper node1:

2181

--replication-factor 1

--partitions 1

--topic my-kafka-topic

b.檢視topic列表

kafka-topics.sh --list --zookeeper node01:

2181

c.如果需要檢視topic的詳細資訊,需要使用describe命令

kafka-topics.sh --describe --zookeeper node1:

2181

--topic test-topic

d.#若不指定topic,則檢視所有topic的資訊

kafka-topics.sh --describe --zookeeper node1:

2181

e.刪除topic

kafka-topics.sh --

delete

--zookeeper node1:

2181

--topic my-kafka-topic

Linux系統檔案在系統中的傳輸

scp file user ip dir 上傳scp user ip file dir 遠端同步,速度快,缺省會忽略,檔案屬性,鏈結檔案,裝置檔案 rsync r 同步目錄 rsync p 同步許可權 rsync o 同步檔案所有人 rsync g 同步檔案所有組 rsync l 同步鏈結 rsyn...

Linux系統安裝kafka步驟

記錄一下在aliyun linux伺服器上安裝kafka的過程 本次安裝的kafka版本為kafka 2.11 2.1.0 注意 kafka的執行依賴於zookeeper 我在安裝kafka之前已經安裝好了zookeeper 並啟動zookeeper 安裝步驟如下 2.上傳到 usr local k...

在skyeye的linux系統中hello測試

有待修改 建議不要安裝skyeye 1.2.8 skyeye的安裝方法可參考 也可到google中搜其它的方法 cd testsuit cd linux cd s3c2410 cd s3c2410x 2.6.14 vim hello.c input include int main usr loca...