#### 创建topic
```
./kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 2 --topic test
```
#### topic扩容
```
./kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic test --partitions 4 --replication-factor 4
```
#### 创建消费组
```
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic --group group
```
#### 删除topic
```
./kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic topic
```
#### 删除消费组
```
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group group
```
#### 切换leader
```
./kafka-preferred-replica-election.sh --bootstrap-server localhost:9092
```
#### 消费组跳到最新
```
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group --reset-offsets --topic topic --to-latest --execute
```
#### 消费组跳到最早
```
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group --reset-offsets --topic topic –-to-earliest --execute
```
#### 集群描述
```
./kafka-topics.sh --describe --bootstrap-server localhost:9092
```
#### topic详情
```
./kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic topic
```
#### topic列表
```
./kafka-topics.sh --list --bootstrap-server localhost:9092
```
#### 消费者列表查询
```
./kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
```
#### 消费组的消费详情
```
./kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group group
```
#### 查看最新offset
```
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group --reset-offsets --topic topic --to-current
```
#### 生产
```
./kafka-console-producer.sh --broker-list localhost:9092 --topic topic
```
#### 消费
```
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic --from-beginning
```