第03节：部署环境 Kafka

一、运维日志

• 在 Docker 容器中安装和配置 Kafka 环境。关于 Kafka 镜像可以在 Docker 官网镜像中搜索 Docker Hub

二、下载镜像

docker pull wurstmeister/kafka docker pull wurstmeister/zookeeper

二、启动 Zookeeper

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

三、启动 Kafka

docker run -d --name kafka \ -p 9092:9092 \ -e KAFKA_BROKER_ID=0 \ -e KAFKA_ZOOKEEPER_CONNECT=换成你的服务器IP:2181 \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://换成你的服务器IP:9092 \ -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka

• 把这个整体命令复制到后台运行，运行前要把服务器IP换成你的

四、防火墙设置

这里我们需要把 Zookeeper、Kafka 的端口对外开放；

• 设置zk 2181 端口：firewall-cmd --zone=public --add-port=2181/tcp --permanent
• 设置Kafka 9092 端口：firewall-cmd --zone=public --add-port=9092/tcp --permanent
• 重新加载：firewall-cmd --reload

五、Kafka 日志

• 在 Docker 容器中可以点击 Kafka 进入日志查看和控制台操作

六、Kafka 控制台操作

• 在 Kafka 控制台可以操作配置文件，查看日志，添加Topic

七、添加 Topic

抽奖系统需要2个Topic，在控制台创建；

• 创建topic lottery_activity_partake：bin/kafka-topics.sh --create --zookeeper 172.17.0.3:2181 --replication-factor 1 --partitions 1 --topic lottery_activity_partake
• 创建topic lottery_invoice：bin/kafka-topics.sh --create --zookeeper 172.17.0.3:2181 --replication-factor 1 --partitions 1 --topic lottery_invoice