导读

由于商城项目需要使用到消息队列，比如登录注册时发送邮箱验证码等，亦或者商城的订单系统，也需要使用到相应的消息队列，这里在CentorOS环境下使用Docker安装下Kafka。

安装步骤

1、下载镜像

  1. #下载zookeeper
  2. docker pull wurstmeister/zookeeper
  4. #下载kafka
  5. docker pull wurstmeister/kafka
  7. #下载kafka-manager,这个可以不用要
  8. docker pull sheepkiller/kafka-manager

2、启动镜像

2.1 启动zookeeper

docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper

2.2 启动kafka

docker run -d --name kafka \
-p 9092:9092 \
-e KAFKA_BROKER_ID=0 \ 
-e KAFKA_ZOOKEEPER_CONNECT=192.168.158.128:2181 \ 
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.158.128:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

格式化后，等同上方：

docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.158.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.158.128:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

注意：这里的IP和下方的IP换成自己的IP即可。

3、测试Kafka

进入docker的kafka容器

#进入容器
docker exec -it ${容器ID} /bin/bash

# 进入
cd /opt/kafka_2.12-2.3.0/

执行下面命令：

#创建topic
bin/kafka-topics.sh --create --zookeeper 129.158.3.25:2181 --replication-factor 1 --partitions 1 --topic mykafka

#查看topic
bin/kafka-topics.sh --list --zookeeper 129.158.3.25:2181

#创建生产者
bin/kafka-console-producer.sh --broker-list 129.158.3.25:9092 --topic mykafka 

#创建消费者
bin/kafka-console-consumer.sh --zookeeper 129.158.3.25:2181 --topic mykafka --from-beginning

创建Topic：
image.png

查看Topic：
image.png

4. 查看topic的状态

在kafka容器中的opt/kafka_2.12-2.3.0/目录下输入

bin/kafka-topics.sh --describe --zookeeper 192.168.204.128:2181 --topic ${你的topic的names}

输出结果：

Topic:mykafka  PartitionCount:2    ReplicationFactor:2 Configs:
    Topic: mykafka Partition: 0    Leader: 0   Replicas: 0,1   Isr: 0,1
    Topic: mykafka Partition: 1    Leader: 0   Replicas: 1,0   Isr: 0,11

显示每个分区的Leader机器为broker0，在broker0和1上具有备份，Isr代表存活的备份机器中存活的。 如图所示：
image.png

当停掉kafka1后.

docker stop mykafka

再查看topic状态，输出结果：

Topic:mykafka  PartitionCount:2    ReplicationFactor:2 Configs:
    Topic: mykafka Partition: 0    Leader: 0   Replicas: 0,1   Isr: 0
    Topic: mykafka Partition: 1    Leader: 0   Replicas: 1,0   Isr: 0

参考