kafka shell 命令列操作

2021-09-03 08:26:18 字數 1032 閱讀 9894

kafka的命令列操作

1、產看當前集群中已存在的主題topic

bin/kafka-topics.sh --list --zookeeper bigdata:2181 

2、建立主題topic

bin/kafka-topics.sh --create --zookeeper bigdata:2181 --replication-factor 1 --partitions 1 --topic test1

--zookeeper 連線zk集群

--create 建立

--replication-factor    副本

--partitions    分割槽

--topic     主題名

3、刪除主題

bin/kafka-topics.sh --delete --zookeeper bigdata:2181 --topic test1

4、傳送訊息(producer)

bin/kafka-console-producer.sh --broker-list bigdata:9092 --topic test

5、接收訊息(consumer)

老版本bin/kafka-console-consumer.sh --zookeeper bigdata:2181 --topic test --from-beginning

新版本啟動方式:

bin/kafka-console-consumer.sh --bootstrap-server bigdata:9092 --topic test --from-beginning

6、檢視主題詳細資訊

bin/kafka-topics.sh --zookeeper bigdata:2181 --describe --topic test

topic:test1    partitioncount:1    replicationfactor:1    configs:

topic: test1    partition: 0    leader: 0    replicas: 0    isr: 0

mysql js 命令列登入 命令列操作

一 安裝nodejs window安裝cnpm npm i g cnpm registry 二 linux命令 安裝nodejs或者cnpm時,因為是全域性安裝的,要用到root許可權,所以要用sodu命令。只要能查到版本號就說明裝好了。1.比如 安裝cnpm sudo npm i g cnpm r...

mysql命令列cmd CMD命令列操作MySQL

連線mysql伺服器 mysql u使用者名稱 p密碼 mysql u使用者名稱 p enter password 輸入密碼 無密碼則直接回車 mysql h主機名 u使用者名稱 p密碼 d資料庫名稱 退出 exit quit q ctrl c 顯示幫助資訊 h 取消本行命令 c 取消當前未完成的操...

mysql 命令列 回車 mysql命令列操作

顯示資料庫 show databases 當前資料庫 select database 顯示表show tables 更改表名稱 alter table 原表名 rename 新錶名 rename table 原表名 to 新錶名 檢視系統支援的引擎 show engines 檢視表的引擎 show ...