kafka环境搭建

我们选择使用docker 安装环境，简化很多的环境文件配置 又因为kafka 依赖于 zk 所以我们要分别使用docker 安装 kafka 和 zk ，那么开始。

下载kafka和Zookeeper镜像文件

docker pull wurstmeister/kafka
docker pull wurstmeister/zookeeper

运行Zookeeper环境

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

运行Kafka环境

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

备注下 ： 192.168.1.5 为本机器的ip地址 。

docker ps 看下是否已经启动成功

进入Kafka容器类

docker exec -it kafka01 /bin/bash

启动成功我们接下来进行创建 my_log 主题

/opt/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.1.5:2181 --replication-factor 1 --partitions 1 --topic my_log

查询创建的主题

/opt/kafka/bin/kafka-topics.sh --list --zookeeper 192.168.1.5:2181

创建主题成功后 我们分别开启两个命令窗口 分别启动生产者和消费者

启动生产者
/opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.1.5:9092 --topic my_log

启动消费者
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.5:9092 --topic my_log --from-beginning

下图左侧命令窗口为生产者 右侧窗口为消费者 可以看见 生产者生产出来的消息 右侧窗口消费者都消费到了

image.png