【kafka】使用docker启动kafka

1.环境准备

docker拉取zookeeper镜像

docker pull zookeeper:3.4.14

创建zookeeper容器，默认端口号为2181

docker run -d --name zookeeper -p 2181:2181 zookeeper:3.4.14

拉取kafka镜像

docker pull wurstmeister/kafka:2.12-2.3.1

创键kafka容器，默认端口号为9092

docker run -d --name kafka 
--env KAFKA_ADVERTISED_HOST_NAME=192.168.117.80 
--env KAFKA_ZOOKEEPER_CONNECT=192.168.117.80:2181 
--env KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.117.80:9092 
--env KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
--env KAFKA_HEAP_OPTS="-Xmx256M -Xms256M" 
--net=host wurstmeister/kafka:2.12-2.3.1

查看是否运行成功

docker logs -f [进程号]

2.创建主题

docker进入kafka容器

docker exec -it 5af197f9ce2a /bin/bash

进入bin目录

首先找到kafka的bin

find / -name kafka

cd进去服务器托管网即可

cd /opt/kafka/bin

创建topic

kafka-topics.sh --create --zookeeper 192.168.117.80:2181 --partitions 1 --replication-factor 1 --topic test

查看topic

kafka-topics.sh --list --zookeeper 192.168.117.80:2181服务器托管网

3.创建消息生产者和消费者

创建生产者

kafka-console-producer.sh --broker-list 192.168.117.80:9092 --topic test

创建消息消费者

从启一个容器实例

根据项目步骤进入到bin目录

创建消息消费者

kafka-console-consumer.sh --bootstrap-server 192.168.117.80:9092 --topic test

4.测试

此时是消费最后一个消息后偏移量+1的消息

若想消费所有消息

kafka-console-consumer.sh --bootstrap-server 192.168.117.80:9092 --topic test --from-beginning

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: MDM介绍：6. 有密码方面问题？远程帮您解决！

“IC、IP、IQ卡，统统告诉我密码!” 相信大家都知道这句幽默的台词。密码，如此重要的信息，能随便告诉别人吗？当然不能，也不能随便就忘记了。QQ密码、微信密码、邮箱密码、手机密码、电脑登录密码、各个软件登录密码、银行卡密码、支付宝密码……如此多的密码，而且有…