Docker中Kafka基本命令使用

### 1、查询kafka所在容器id
```shell
docker ps | grep kafka
```
如下<bold>5de5bcb206bf</bold>就为容器id
```txt
[root@localhost ~]# docker ps | grep kafka
5de5bcb206bf   wurstmeister/kafka   "start-kafka.sh"         25 hours ago   Up 10 minutes   0.0.0.0:9092->9092/tcp, :::9092->9092/tcp                                 kafka

```
### 2、进入容器
```shell
docker exec -it 容器id /bin/bash
```
例如：
```txt
docker exec -it 5de5bcb206bf /bin/bash
```
### 3、创建topic
进入bin目录
```txt
cd /opt/kafka/bin
```
创建一个名称为test2的topic
```txt
kafka-topics.sh --create --zookeeper 192.168.83.128:2181/kafka --replication-factor 1 --partitions 1 --topic test2
```

参数说明

--zookeeper 表示ZK地址，可以传递多个，用逗号分隔 IP:PORT,IP:PORT,IP:PORT/kafka
	zookeeper中的ip地址是和容器的名称对应的，写你对应的容器名称就可以。。。
	--replication-factor 表示副本数量，这里的数量是包含Leader副本和Follower副本，副本数量不能超过代理数量
	--partitions 表示主题的分区数量，必须传递该参数。Kafka的生产者和消费者采用多线程并行对主题的消息进行处理，每个线程处理一个分区，分区越多吞吐量就会越大，但是分区越多也意味着需要打开更多的文件句柄数量，这样也会带来一些开销。

### 4、对topic进行查询

kafka-topics.sh --zookeeper 192.168.83.128:2181/kafka --list
### 5、对topic进行删除

kafka-topics.sh --zookeeper 192.168.83.128:2181/kafka --delete --topic test3 
### 6、对topic的信息进行获取

kafka-topics.sh --zookeeper 192.168.83.128:2181/kafka --describe --topic test2

### 7、生产者发送消息、消费者消费消息

生产者发送消息命令:

kafka-console-producer.sh --broker-list  localhost:9092 --topic test2

消费者接受消息命令:

kafka-console-consumer.sh --bootstrap-server  localhost:9092 --topic test2