docker搭建简易kafka

绝地灬酷狼 2023-06-06 12:05 99阅读 0赞

本章主要是为了记录部署指令

搭建zookeeper

运行容器

  1. docker run -d \
  2. -p 2181:2181 \
  3. -v /Users/qiuwei/Desktop/qw/docker/zookeeper/data/:/data/ \
  4. --name=zookeeper  \
  5. --privileged zookeeper

搭建kafka

拉取镜像

  1. docker pull wurstmeister/kafka

运行容器

  1. docker run  -d --name kafka \
  2. -p 9092:9092  \
  3. --env KAFKA_ADVERTISED_HOST_NAME=localhost  \
  4. -e KAFKA_ZOOKEEPER_CONNECT=172.30.66.35:2181 \
  5. -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.30.66.35:9092 \
  6. -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
  7. -e KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"  --net=host wurstmeister/kafka

kafka默认端口是9092

测试

运行kafka创建一个topic : test

进入容器

  1. docker exec -it kafka bash

进入目录

  1. cd /opt/kafka_2.11-2.0.0/bin/

创建一个test topic

  1. ./kafka-topics.sh --create --zookeeper 172.30.66.35:2181 --replication-factor 1 --partitions 8 --topic test

启动 producer

  1. ./kafka-console-producer.sh --broker-list localhost:9092 --topic test

在这里插入图片描述

重新开启一个窗口
启动 consumer

  1. ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

在这里插入图片描述

参考: https://blog.csdn.net/belonghuang157405/article/details/82149257

发表评论

表情：
评论列表 （有 0 条评论，99人围观）

还没有评论，来说两句吧...

相关阅读

    相关 docker简易搭建kafka

    写在前面：在我们大量使用分布式数据库、分布式计算集群的时候，是否会遇到这样的一些问题：想分析一下用户行为，一遍我能设计出更好的广告位，相对用户的搜索关键字尽心统计，分析出前卫的

    以你之姓@以你之姓@/ 0 赞/ 454 阅读