03、 Kafka单机环境部署
1、 Docker 安装单机版本搭建
（1）安装Zookeeper
docker pull zookeeper
（2）启动zookeeper
docker run -d --name zookeeper -p 2181:2181 zookeeper
（3）安装 Kafka
docker pull wurstmeister/kafka
（4）启动Kafka
docker run -d --name kafka -p 9092:9092 --link zookeeper:zookeeper \
-v /usr/kafka/config/server.properties:/config/server.properties \
--env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
--env KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 \
--env KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
--env KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 \
wurstmeister/kafka
–name kafka: 设置容器的名字为“kafka”。
-p 9092:9092: 将容器的9092端口映射到宿主机的9092端口。
–link zookeeper:zookeeper: 连接到名为“zookeeper”的另一个Docker容器，并且在当前的容器中可以通过zookeeper这个别名来访问它。
–env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181: 设置环境变量，指定ZooKeeper的连接字符串。
–env KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092: 设置环境变量，指定Kafka的advertised listeners。
–env KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092: 设置环境变量，指定Kafka的listeners。
–env KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1: 设置环境变量，指定offsets topic的副本因子。
wurstmeister/kafka: 使用的Docker镜像名字。
（5）查看启动的实例
docker ps
2、测试Kafka功能
（1）进入 Kafka 容器
docker exec -it kafka bash
（2）进入Kafka的bin目录
cd /opt/kafka_2.13-2.8.1/bin
（3）创建 topic
kafka-topics.sh --create \
> --bootstrap-server localhost:9092 \
> --topic test \
> --replication-factor 1 \
> --partitions 1
–bootstrap-server：指定Kafka 工作节点
–topic：指定 topic 主题名称
–replication-factor：指定副本因子，容错处理，做多少个副本。
–partitions：指定分区数。
查看已有的 topic：
kafka-topics.sh --list --bootstrap-server localhost:9092
（4）开启生产者，指定主题topic 为 test。
kafka-console-producer.sh \
> --broker-list localhost:9092 \
> --topic test
（5）另外打开一个窗口，开启消费者，订阅 test。
kafka-console-consumer.sh \
> --bootstrap-server localhost:9092 \
> --topic test
（6）在生产者窗口，发送消息 hello world
消费者窗口，就会收到
到此为止，我们的 kafka基本功能就测试完成了。
