Kafka 入門命令

消費者組

消費者和生產者

檢視幫助

kafka -topics-- zookeeper localhost:2181-- create-- topic money-- replication -factor3- -partitions8- -if-not -exists//- -partitions 分割槽數//-- zookeeper zk位址，多個使用逗號分隔//- -replication -factor 複製係數

kafka -topics-- zookeeper localhost:2181-- alter-- topic money-- partitions

16

只可以增加，不可以減少，因為減少會導致資料不一致

kafka -topics-- zookeeper localhost:2181-- delete-- topic money

kafka -topics-- zookeeper localhost:2181-- list

kafka -topics-- zookeeper localhost:2181-- descirbe

舊消費者

kafka-consumer -groups --zookeeper localhost:2181 --list

新消費者客戶端，因為在0.10.2之後偏移量儲存在kafka上

kafka-consumer -groups --bootstrap-server kafka1:9092,kafka2:9093,kafka3:9094 --list

kafka -consumer -groups-- zookeeper localhost:2181-- descibe-- group test

kafka-consumer -groups --bootstrap-server kafka1:9092,kafka2:9093,kafka3:9094 --describe -- group test1

字段

解釋group

群組名稱

topic

主題名稱

partition

分割槽id

current-offset

分割槽當前偏移量

log-end-offset

分割槽高水位

lag消費者和高水位的差距，就是還有幾條訊息沒有消費

client-id

消費者id

kafka -consumer -groups-- zookeeper localhost:2181-- delete-- group test1

kafka-consumer -groups --bootstrap-server kafka1:9092,kafka2:9093,kafka3:9094 --delete -- group test1

kafka -configs-- zookeeper zk:2181-- entity -type topics/clients-- entity -name ***- -add -config[,]

kafka -console -consumer.sh --zookeeper locahost:2181-- topic test

kafka-console -consumer --bootstrap-server kafka1:9092,kafka2:9093,kafka3:9094 --topic money --from-beginning

kafka-console-producer --broker-list kafka1 :9092,kafka2 :9093,kafka3 :9094 --topic money

對應命令 help

如：

kafka-console -producer help

Kafka 入門命令

kafka啟動命令 Kafka入門

kafka入門基礎命令

kafka入門簡介

Kafka 入門命令

kafka啟動命令 Kafka入門

kafka入門基礎命令

kafka入門簡介

相關推薦