kafka命令大全

## 建立主題（4個分割槽，2個副本）

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic test

## 查詢集群描述

bin/kafka-topics.sh --describe --zookeeper

## topic列表查詢

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

## topic列表查詢（支援0.9版本+）

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

## 新消費者列表查詢（支援0.9版本+）

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list

## 新消費者列表查詢（支援0.10版本+）

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

## 顯示某個消費組的消費詳情（僅支援offset儲存在zookeeper上的）

bin/kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper localhost:2181 --group test

## 顯示某個消費組的消費詳情（0.9版本 - 0.10.1.0 之前）

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

## 顯示某個消費組的消費詳情（0.10.1.0版本+）

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group

傳送和消費

## 生產者

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

## 消費者

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test

## 新生產者（支援0.9版本+）

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test --producer.config config/producer.properties

## 新消費者（支援0.9版本+）

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --new-consumer --from-beginning --consumer.config config/consumer.properties

## 高階點的用法

bin/kafka-******-consumer-shell.sh --brist localhost:9092 --topic test --partition 0 --offset 1234 --max-messages 10

bin/kafka-preferred-replica-election.sh --zookeeper zk_host:port/chroot

bin/kafka-producer-perf-test.sh --topic test --num-records 100 --record-size 1 --throughput 100 --producer-props bootstrap.servers=localhost:9092

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --partitions 2

kafka命令大全

kafka系列教程03 kafka命令大全

Kafka常用命令大全

Kafka監控元件大全

kafka命令大全

kafka系列教程03 kafka命令大全

Kafka常用命令大全

Kafka監控元件大全

相關推薦