『Kafka』在Docker中快速部署Kafka及其管理平台搭建

这篇具有很好参考价值的文章主要介绍了『Kafka』在Docker中快速部署Kafka及其管理平台搭建。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节
📣读完这篇文章里你能收获到

  • 在Docker中快速部署Kafka
  • 在Docker中快速部署Zookeeper
  • 搭建Kafka管理平台
  • Kafka部署测试
  • 感谢点赞+收藏,避免下次找不到~

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

一、部署Zookeeper

1 拉取Zookeeper镜像

docker pull wurstmeister/zookeeper

2 运行Zookeeper

docker run --restart=always --name zookeeper \
--log-driver json-file \
--log-opt max-size=100m \
--log-opt max-file=2  \
-p 2181:2181 \
-v /etc/localtime:/etc/localtime \
-d wurstmeister/zookeeper

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

二、部署Kafka

1 拉取Kafka镜像

docker pull wurstmeister/kafka

2 运行Kafka

docker run --restart=always --name kafka \
--log-driver json-file \
--log-opt max-size=100m \
--log-opt max-file=2 \
 -p 9092:9092 \
 -e KAFKA_BROKER_ID=0 \
 -e KAFKA_ZOOKEEPER_CONNECT=192.168.8.102:2181 \
 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.8.102:9092 \
 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
 -v /etc/localtime:/etc/localtime \
 -d wurstmeister/kafka

参数说明:
-e KAFKA_BROKER_ID=0 在kafka集群中,每个kafka都有一个BROKER_ID来区分自己
-e KAFKA_ZOOKEEPER_CONNECT=172.16.0.13:2181/kafka 配置zookeeper管理kafka的路径172.16.0.13:2181/kafka
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.16.0.13:9092 把kafka的地址端口注册给zookeeper,如果是远程访问要改成外网IP,类如Java程序访问出现无法连接。
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口
-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

三、验证是否部署成功

1 进入到kafka容器中

docker exec -it kafka /bin/sh

2 创建topic 生产者

cd opt/kafka_2.13-2.8.1

bin/kafka-topics.sh --create --zookeeper 192.168.8.102:2181 --replication-factor 1 --partitions 1 --topic partopic

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

3 生产者发送消息

bin/kafka-console-producer.sh --broker-list 192.168.8.102:9092 --topic partopic

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

4 消费者消费消息

  • 新打开个ssh窗口
  • 跟前面步骤一样进入到容器
bin/kafka-console-consumer.sh --bootstrap-server 192.168.8.102:9092 --topic partopic --from-beginning

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节

四、搭建kafka管理平台

1 拉取kafka-manager镜像

docker pull docker.io/sheepkiller/kafka-manager

2 运行kafka-manager

docker run --restart=always --name kafka-manager \
-p 9000:9000 \
-e ZK_HOSTS="192.168.8.102:2181"  \
--net=host \
-d sheepkiller/kafka-manager

3 实操步骤

wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节
wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节
wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节
wurstmeister/kafka,# 『MQ消息队列』,kafka,docker,java,1024程序员节文章来源地址https://www.toymoban.com/news/detail-571833.html

到了这里,关于『Kafka』在Docker中快速部署Kafka及其管理平台搭建的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【中间件】通过 docker-compose 快速部署 Kafka 保姆级教程

    Kafka是由Apache基金会开发的分布式流处理平台,采用发布-订阅模式,支持高吞吐量、低延迟的数据传输。主要用于处理实时数据管道、数据存储和数据分析等大数据应用场景。Kafka采用高效的数据压缩算法,可以在集群中存储大量的数据,并通过分区机制来实现数据的高可靠

    2024年02月12日
    浏览(37)
  • 【靶场搭建】docker搭建CTFd平台&题库部署

    目录 安装docker和docker-compose 搭建CTFd平台 部署CTF题目 CTFd平台创建题目 (1)安装docker: curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun (2)安装 Docker Compose: apt-get install docker-compose (3)验证一下是否安装成功: mkdir CTFd         #创建一个文件夹CTFd cd CTFd git clone h

    2024年03月22日
    浏览(32)
  • 实战详解Docker快速搭建部署ELK

    一.安装前须知 以下步骤在 VMware 中的 centos 7 中操作,ip 地址为:192.168.161.128; 注意安装的时候最好统一版本,否则后面会出现许多问题,进官网搜索对应镜像,查看 Tags 标签下的版本,目前我这最新的 Tags 是 7.12.1,所以拉取镜像时统一加上该版本号。官网镜像地址 Docker 搭

    2024年02月07日
    浏览(30)
  • docker+jenkins+gitee搭建自动部署平台

    linux上没有安装docker的看下面的这篇文章: Linux安装docker-CSDN博客 文章浏览阅读149次。Linux安装docker https://blog.csdn.net/weixin_39075154/article/details/135610942?spm=1001.2014.3001.5501 -d : 启动容器并以“分离”模式运行,即在后台运行。 --name jenkins : 为容器指定一个名称“jenkins”,便于后续

    2024年01月20日
    浏览(39)
  • Jenkins+Docker+Gitee搭建自动化部署平台

    目录 服务器准备 Docker安装 yum 包更新到最新 设置yum源 安装docker 启动和开机启动 验证安装是否成功 Jenkins安装 拉取镜像 创建映射目录 运行镜像 运行出错 修正权限 重新运行镜像 新建安全组,放通8080端口 激活Jenkins Jenkins插件 Jenkins全局工具配置 自动构建Springboot项目 准备好

    2024年02月04日
    浏览(40)
  • 使用dockerfile以及docker compose部署搭建wordpress平台

    Dockerfile 是一个文本文件,其中包含了构建 Docker 镜像的指令。它描述了镜像的构建过程,包括基础镜像、安装的软件、配置信息等。   Dockerfile 以指令的形式定义了构建镜像的步骤,每一行指令都是一个独立的步骤。这些指令可以包括从官方仓库获取基础镜像、运行命令、添

    2024年02月22日
    浏览(41)
  • WeBASE管理平台快速入门搭建(单群主4节点联盟链+WeBASE-Front)

    WeBASE是区块链应用和FISCO BCOS节点之间搭建的中间件平台可以帮助开发者快速构建、测试和部署基于FISCO BCOS的区块链应用,支持智能合约开发模板、合约API管理、账户管理、链上操作记录查询等功能。同时,WeBASE还提供了多样化的安全保障措施,如合约审计、用户权限控制、

    2024年02月08日
    浏览(26)
  • 使用 Docker Compose V2 快速搭建日志分析平台 ELK (Elasticsearch、Logstash 和 Kibana)

    ELK 是指 Elasticsearch、Logstash 和 Kibana 这三个开源软件的组合。 Elasticsearch 是一个分布式的搜索和分析引擎,用于日志的存储,搜索,分析,查询。 Logstash 是一个数据收集、转换和传输工具,用于收集过滤和转换数据,然后将其发送到 Elasticsearch 或其他目标存储中。 Kibana 是一个数

    2024年01月20日
    浏览(42)
  • halo搭建炫酷个人博客快速部署:docker+docker-compose+nginx

    🏠 服务器与网站部署知识体系目录 部署一个炫酷的个人博客只需要按照本文的指令直接 cv 即可。 但请注意打开服务器防火墙的 80 和 3306 端口。 Halo是一款现代化的开源博客/CMS系统,所有代码开源在GitHub上且处于积极维护状态。它是基于 Java Spring Boot 构建的,易于部署,支

    2024年02月08日
    浏览(50)
  • docker快速部署oracle19c、oracle12c,测试环境问题复现demo快速搭建笔记

    (复制sql,替换表名执行完毕后,再修改自己想要的字段即可) (复制sql,替换自己的表名) 一个oracle表示一个实例,一个实例可以配置多个服务,独立维护的oracle服务 一个服务内可以有多个表空间,默认表空间就有很多,比如常见的SYSTEM、TEMP、USERS 常见的默认角色: 1、

    2024年02月04日
    浏览(45)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包