为了方便,直接用docker安装kafka进行开发环境.
1.首先下载镜像
ps:鉴于国内的环境,建议先设置docker国内镜像.
这里使用了wurstmeister/kafka和wurstmeister/zookeeper这两个版本的镜像
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
2.创建启动镜像
先启动zookeeper:
docker run -d –name zookeeper –publish 2181:2181 \
–volume /etc/localtime:/etc/localtime \
zookeeper:latest
zookeeper启动完成后再启动kafka:
docker run -d –name kafka –publish 9092:9092 \
–link zookeeper \
–env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
–env KAFKA_ADVERTISED_HOST_NAME=docker机器的IP \
–env KAFKA_ADVERTISED_PORT=9092 \
–volume /etc/localtime:/etc/localtime \
wurstmeister/kafka:latest
3. 测试消息
进入kafka容器
docker exec -it kafka /bin/bash
进入kafka目录-这里的版本号可能能升级
cd /opt/kafka_2.12-1.0.0
创建主题:
bin/kafka-topics.sh –create –zookeeper zookeeper:2181 –replication-factor 1 –partitions 1 –topic mykafka
运行消息 生产者
bin/kafka-console-producer.sh –broker-list localhost:9092 –topic mykafka
然后输入一些信息
运行消息 消费者
bin/kafka-console-consumer.sh –zookeeper zookeeper:2181 –topic mykafka –from-beginning