kafka常用命令

环境准备

```txt
        域名 : ip
主机1   test1:192.168.225.128
主机2   test2:192.168.225.129
主机3   test3:192.168.225.130
```

以下命令都是在kafka中bin目录下执行

## kafka-topics.sh 脚本使用之topic

### 创建topic

#创建一个名为 first的topic指定分区数为1，副本数为3，
	./kafka-topics.sh --bootstrap-server test1:9092,test2:9092,test3:9092 --topic first --create --partitions 1 --replication-factor 3
	
### 查询topic

./kafka-topics.sh --bootstrap-server test1:9092 --list
	
### 修改分区数

#将分区由1个改为两个，注意只能改多不能减少
	./kafka-topics.sh --bootstrap-server test1:9092 --topic first --alter --partitions 2

### 查看详细描述

./kafka-topics.sh --bootstrap-server test1:9092 --describe

## kafka-console-producer.sh 脚本使用 生产者

kafka-console-producer.sh --bootstrap-server test1:9092 --topic first
	
## kafka-console-consumer.sh 脚本使用 消费者

```txt
# 读取新数据
./kafka-console-consumer.sh --bootstrap-server test1:9092 --topic first
# 读取历史数据
./kafka-console-consumer.sh --bootstrap-server test1:9092 --topic first --from-beginning
```