kafka安裝整理，附帶常用命令

2021-10-23 11:35:30 字數 1460 閱讀 8292

// 配置環境變數

export kafka_home=


/opt/kafka


export path=$path:$kafka_home/bin
// 啟動kafka

普通啟動和後台啟動

kafka-server-start.sh ./config/server.properties


kafka-server-start.sh -daemon ./config/server.properties
// 建立topic

kafka-topics.sh --create --zookeeper 192.168


.255


.11:


2181


--topic kb07demo --partitions 3


--replication-factor 1
// 檢視當前kafka中的topic

kafka-topics.sh --zookeeper 192.168


.255


.11:


2181


--list
// 檢視topic詳情

kafka-topics.sh --zookeeper 192.168


.255


.11:


2181


--describe --topic kb07demo
// 刪除topic

kafka-topics.sh --zookeeper 192.168


.255


.11:


2181


--delete --topic kb07demo
// 建立生產者，產生資料

kafka-console-producer.sh --topic kb07demo --broker-list 192.168


.255


.11:


9092
// 建立消費者，重頭開始取資料

kafka-console-consumer.sh --bootstrap-server 192.168


.255


.11:


9092


--topic kb07demo --from-beginning
// 檢視topic訊息佇列數量

kafka-run-


class


.sh kafka.tools.getoffsetshell --broker-list 192.168


.255


.11:


9092


--topic kb07demo -time -


1--offsets 1

kafka常用命令整理

kafka常用命令 在launcher上，cd usr local kafka 2.11 0.9.0.0 bin 檢視topic的list kafka topics.sh zookeeper 192.168.1.60 2181,192.168.1.61 2181,192.168.1.62 2181 ...

kafka常用命令

kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...

kafka常用命令

啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...