使用Docker安装Kafka

news2024/12/23 10:22:52

第一步:使用下述命令从Docker Hub查找镜像,此处我们要选择的是zookeeper官网的镜像

docker search zookeeper

第二步:拉取zookeeper镜像

docker pull zookeeper:latest

第三步:启动zookeeper容器

docker run -d --name zookeeper -p 2181:2181 -t zookeeper:latest

第四步:拉取kafka镜像,此处选择的是 wurstmeister/kafka (这个镜像的受欢迎程度最高)

docker pull wurstmeister/kafka:latest

第五步:如果是在Windows系统中可以使用下述命令启动kafka容器

docker run  -d --name kafka -p 9092:9092 -e KAFKA_ZOOKEEPER_CONNECT=192.168.1.75:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.1.75:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e KAFKA_HEAP_OPTS="-Xmx256M -Xms128M" -e TZ="Asia/Shanghai" wurstmeister/kafka:latest

如果是在Linux中则可以使用下述命令启动kafka容器: 

docker run  -d --name kafka -p 9092:9092 \
-e KAFKA_ZOOKEEPER_CONNECT=192.168.1.75:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.1.75:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
-e KAFKA_HEAP_OPTS="-Xmx256M -Xms128M" \
-e TZ="Asia/Shanghai" \
wurstmeister/kafka:latest

二者的区别就是对于 “\ 符号的支持,其它的配置都一样。

KAFKA_ZOOKEEPER_CONNECT:配置zookeeper服务的地址

KAFKA_ADVERTISED_LISTENERS:zookeeper中存的地址是此处配置的,多个kafka注册到zookeeper就是把这个地址放到zookeeper中。 

KAFKA_LISTENERS:内网部署的程序,读的地址是KAFKA_LISTENERS写的,配置0.0.0.0:9092,表示内网所有网卡都绑定9092

TZ:容器时区改为上海

如果当前服务参数需要调整,可以参考wurstmeister在github上的官网地址:

https://github.com/wurstmeister/kafka-docker

第六步:使用下述命令进入都kafka容器内部,然后进入到 /opt/kafka_2.13-2.8.1/bin 目录下

docker exec -it kafka bash
cd /opt/kafka_2.13-2.8.1/bin

可以看到这里有着许多和kafka操作命令相关的脚本文件。

第七步:使用下述命令创建一个单分区单副本的主题 test123,并且创建生产者生产消息

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test123
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test123

接着另起一个连接创建消费者接收消息:

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test123 --from-beginning

如上图所示,当看到消费者获取到了生产者发送的消息则说明kafka服务启动成功。 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/592884.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

微服务-Elasticsearch基础篇【内含思维导图】

Elasticsearch官网:欢迎来到 Elastic — Elasticsearch 和 Kibana 的开发者 | Elastic 注意:Elasticsearch官网访问和加载的耗时很长!!! Lucene官网:Apache Lucene - Welcome to Apache Lucene 目录 一、E…

Docker基本操作与自定义镜像Docker-Compose与Docker镜像仓库

目录 一.基本操作 1.镜像操作 1.1.镜像名称 1.2.镜像命令 1.3.案例-拉取、查看镜像 1.4.案例-保存、导入镜像 2.容器操作 2.1.容器相关命令 2.2.案例-创建并运行一个容器 2.3.案例-进入容器,修改文件 2.4.小结 3.数据卷(容器数据管理&#x…

挑选在线帮助文档协作工具的技巧与要点

随着互联网的发展,越来越多的公司和团队开始使用在线帮助文档协作工具来共同编辑和维护文档。这些工具可以让多个用户同时协作编辑同一篇文档,从而提高工作效率和减少沟通成本。然而,在选择在线帮助文档协作工具时,需要注意一些技…

低代码平台投票榜揭晓:这些平台最受欢迎

低代码平台是软件开发工具,允许用户快速轻松地创建和部署应用程序,只需最少的编程知识。对于寻求在不需要大量IT资源的情况下构建自定义应用程序的企业来说,这些平台非常有用。在本文中,我们将讨论低代码平台排行榜投票榜&#xf…

注解和反射复习

注解 注解:给程序和人看的,被程序读取,jdk5.0引用 内置注解 override:修饰方法,方法声明和重写父类方法, Deprecated:修饰,不推荐使用 suppressWarnings用来抑制编译时的警告,必须添加一个或多个参数s…

外贸客户背调的几种干货技巧

外贸人要想做到知己知彼,那背调是必不可少的。 有经验的外贸人会通过关键词、邮箱等开展模糊搜索,然而这种方式不光效率低,而且搜索到的信息也不全。今天小编分享的这几种背调组合工具,不光收集到的客户信息全面,而且…

Nginx网络服务的配置(叫不醒和睡不着的是两个世界)

文章目录 一、Nginx概述二、Nginx相对于Apache的优点三、配置Nginx网络服务1.编译安装和启用Nginx服务(1)关闭防火墙和selinux(2)安装依赖包(3)创建运行用户、组(Nginx 服务程序默认以 nobody 身…

华为OD机试真题B卷 Java 实现【机房布局】,附详细解题思路

一、题目描述 小明正在规划一个大型数据中心机房,为了使得机柜上的机器都能正常满负荷工作,需要确保在每个机柜边上至少要有一个电箱。 为了简化题目,假设这个机房是一整排,M表示机柜,I表示间隔,请你返回…

北斗RTK差分定位技术原理、优势及应用领域

北斗卫星导航系统是中国自主建设的卫星导航系统,是继美国GPS、俄罗斯GLONASS和欧盟Galileo之后,全球第四个卫星导航系统。北斗系统非常重要,可用于国防、公共安全、民生等多个领域,包括交通运输、环境保护、渔业等。差分定位则是北…

【Springboot系列】springboot扩展点大整理,赶紧收藏起来

系列文章:Spring Boot学习大纲,可以留言自己想了解的技术点 1、aware系列 在Spring Boot中,有一些可以实现的Aware接口,用于在应用程序中获取特定的上下文或对象。这些接口允许您的组件意识到它们所在的环境,并与之进…

和数集团元宇宙场景落地 催生新机遇

现代社会随着科技不断发展,人们对于虚拟现实的需求日益提高。随着互联网进入Web3.0时代,越来越多的人开始进入虚拟世界,探索虚拟现实的无限可能。 在这个充满未知的广阔世界中,和数集团旗下包括【神念无界源起山海】、【神宠岛】…

国内使用chatGPT插件

无需任何繁琐操作,只要你一打开edge浏览器就能使用chatGPT,还要什么自行车! 那么如何使用呢?其实操作是非常简单的! 步骤 第一步:下载edge浏览器 edge浏览器一般Windows10系统都自带了,没有的…

ChatGPT 提示的艺术 —— 如何编写清晰有效提示指南

ChatGPT 提示的作用 正如我们之前提到的那样,ChatGPT 对话中使用的提示的质量可以显著影响对话的成功。定义清晰的提示可以确保对话保持在正确的轨道上,并涵盖用户感兴趣的主题,从而产生更引人入胜和信息丰富的体验。 那么什么样的 ChatGPT…

计算机网络实验:认识Packet Tracer软件

目录 前言实验目的实验内容及要求相关知识点实验指导实验过程总结 前言 计算机网络是当今信息技术的重要组成部分,它涉及到多种硬件和软件的协同工作,以实现数据的传输和交换。为了更好地理解和掌握计算机网络的基本原理和技术,我们需要进行…

关于分数的二进制原反补码的求解

话不多说,上例子 求-53/64的原反补; 前奏:-53/64可以分解为符号位“-”和数字位53/64; 第一步:在计算机中,符号位用0表示“”用1表示“-” 第二步:求53/64的二进制数,过程如下图…

如何回馈 Elastic 社区

作者:Ully Sampaio 在 Elastic 社区中拥有前排座位最美妙的事情之一就是见证人们互相帮助。 从讨论和 Elastic Community Slack 工作区到 Elastic YouTube 官方频道,无论你走到哪里,你都会看到 Elasticsearch 专家和初学者分享他们的知识。 这…

图解LeetCode——543. 二叉树的直径

一、题目 给你一棵二叉树的根节点,返回该树的 直径 。 二叉树的 直径 是指树中任意两个节点之间最长路径的 长度 。这条路径可能经过也可能不经过根节点 root 。 两节点之间路径的 长度 由它们之间边数表示。 二、示例 2.1> 示例 1: 【输入】roo…

Vision Transformer (ViT)及各种变体

目录 0.Vision Transformer介绍 1.ViT 模型架构 1.1 Linear Projection of Flattened Patches 1.2 Transformer Encoder 1.3 MLP Head 1.4 ViT架构图 1.5 model scaling 2.Hybrid ViT 4.其他Vision Transformer变体 5.Vit代码 6.参考博文 0.Vision Transformer介绍 …

样本不平衡的解决办法

背景 Focal loss是最初由何恺明提出的,最初用于图像领域解决数据不平衡造成的模型性能问题。本文试图从交叉熵损失函数出发,分析数据不平衡问题,focal loss与交叉熵损失函数的对比,给出focal loss有效性的解释。 交叉熵损失函数…

危机先知:TOOM舆情监控助力风险预警

随着社交媒体和互联网的普及,公众的声音在网络上如洪水般涌现。这些声音传递着情绪、态度和观点,对个人、组织甚至整个社会产生着巨大影响。因此,舆情监控成为了一个不可或缺的工具,帮助企业和组织及时了解公众对其品牌、产品或服…