当前位置： 首页 > news >正文

docker 安装kafka

news 文章来源：https://blog.csdn.net/weixin_53150299/article/details/133589444 2025/1/30 14:54:06

运行容器 zookeeper:

[root@k8s-master ~]# docker run -d --restart=always --log-driver json-file --log-opt max-size=100m --log-opt max-file=2  --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime zookeeper
c603f292813cfd6e2b16fff88a9767cc86fc9bba34d82723e57a30a6199d280b

运行容器  kafka:

[root@k8s-master ~]# docker run -d --restart=always --log-driver json-file --log-opt max-size=100m --log-opt max-file=2 --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.21.10.10:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.21.10.10:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka
d545f44cda8eae5f6653efe9ed55b2dd98a29a63648308f0ed6908f5cf841efe
参数说明：
-e KAFKA_BROKER_ID=0  在kafka集群中，每个kafka都有一个BROKER_ID来区分自己-e KAFKA_ZOOKEEPER_CONNECT=172.21.10.10:2181/kafka 配置zookeeper管理kafka的路径172.21.10.10:2181/kafka-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.21.10.10:9092  把kafka的地址端口注册给zookeeper，如果是远程访问要改成外网IP,类如Java程序访问出现无法连接。-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间

[root@k8s-master ~]# docker exec -it kafka bash
bash-5.1# 
bash-5.1#  

 生产者

bash-5.1# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
>helloworld             
>

运行消费者:

运行消费者:

 

 

相关文章：

docker 安装kafka

运行容器 zookeeper: [rootk8s-master ~]# docker run -d --restartalways --log-driver json-file --log-opt max-size100m --log-opt max-file2 --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime zookeeper c603f292813cfd6e2b16fff88a9767cc86fc9bba34d82…...

编程日记 2023/10/6 1:50:40

容器内获得apiserver地址

1.容器的Env的KUBENETES_SERVICE_HOST字段 roottomcat01-69fc8f859b-w9btn:/tmp# env | grep KUBERNETES_SERVICE_HOST10.96.0.1 KUBERNETES_SERVICE_HOST10.96.0.12.通过域名查询 nslookup getent hosts roottomcat01-69fc8f859b-w9btn:/tmp# getent hosts kubernetes.def…...

编程日记 2023/10/6 1:48:38

linux服务端c++开发工具介绍（vscode版）

本文适合于有一定c开发经验，但是还不明确如何到linux服务端开发程序的同学。 一、vscode 几年前用的是ssh到云服务上，再用vim在云上开发的形式 ssh dongbeijing.dbj11.158.142.176 vim hello.c 现今，由于vscode比较好用，这几年…...

编程日记 2023/10/6 1:47:37

Linux常用命令大全

Linux常用命令大全 一、文件&目录管理1. 文件和目录操作命令2. 查看文件及内容处理命令3. 文件压缩及解压缩命令4. 搜索文件命令5. 其他 二、Linux 软件包管理三、用户管理1. 用户管理2. 查看系统用户登陆信息的命令 四、进程管理五、网络通信1. 基础网络操作命令2. 深入网…...

编程日记 2023/10/6 1:46:36

Python中取2023, 9, 1——2023, 10, 31的全部时间

使用datetime.date()函数定义了开始和结束日期。然后，我们使用datetime.timedelta()类创建了一个时间范围，其中n表示从开始日期到结束日期之间的天数。最后，我们使用一个for循环迭代时间范围内的日期，并打印每个日期。示例代码演示…...

编程日记 2023/10/6 1:39:28

创建django文件

1、在指定目录里打开终端，输入D:\Softwares\Anaconda3\envs\pytorch\Scripts\django-admin .exe startproject 名称 ，即可在对应目录里创建django文件。...

编程日记 2023/10/6 1:37:26

全排列[中等]

优质博文：IT-BLOG-CN 一、题目 给定一个不含重复数字的数组nums，返回其所有可能的全排列。你可以按任意顺序返回答案。 示例 1： 输入：nums [1,2,3] 输出：[[1,2,3],[1,3,2],[2,1,3],[2,3,1],[3,1,2],[3,2,1]] 示例…...

编程日记 2023/10/6 1:36:26

mybatise-plus的id过长问题

一、问题情景 笔者在做mp插入数据库(id已设置为自增)操作时，发现新增数据的id过长，结果导致前端JS拿到的数据出现了精度丢失问题，原因是后端id的类型是Long。在网上查了一下，只要在该属性上加上如下注解就可以 TableId(value &q…...

编程日记 2023/10/6 1:32:22

图示矩阵分解

特征值与特征向量 设 A A A 是 n 阶矩阵，如果存在数 λ \lambda λ 和 n 维非零列向量 x x x，满足关系式： A x λ x ( 1 ) Ax \lambda x\quad\quad(1) Axλx(1) 则数 λ \lambda λ 称为矩阵 A A A 的特征值，非零向量 x…...

编程日记 2023/10/6 1:31:21

六、互联网技术——数据存储

文章目录 一、存储系统层次结构二、按照重要性分类三、磁盘阵列RAID三、RAID基础四、磁盘阵列分级五、数据备份与恢复六、容灾与灾难恢复 一、存储系统层次结构 常见的三层存储体系结构如下图所示，分为高速缓冲存储器、主存储器和外存储器。 二、按照重要性分类 …...

编程日记 2023/10/6 1:30:20

六、vpp 流表+负载均衡

草稿！！！ vpp node其实就是三个部分 1、plugin init 2、set command 3、function 实现功能，比如这里的流表 今天我们再用VPP实现一个流表的功能 一、流表 1.1流表----plugin init VLIB_REGISTER_NODE 注册流表节点 // 注册流…...

编程日记 2023/10/6 1:28:19

word已排序好的参考文献，插入新的参考文献，序号更新

原排序好的文献序号。 现在在3号后面插入一个新文献。4，5号应该成为5，6 这时在3号后面，回车，就会自动的增长。如下图： 但是如果手滑，把[4]删除了如何排序？？ 如下图： …...

编程日记 2023/10/6 1:27:18

二叉树的顺序存储——堆——初识堆排序

前面我们学过可以把完全二叉树存入到顺序表中，然后利用完全二叉树的情缘关系，就可以通过数组下标来联系。 但是并不是把二叉树存入到数组中就是堆了，要看原原来的二叉树是否满足：所有的父都小于等于子，或者所有的父都…...

编程日记 2023/10/6 1:26:16

CYEZ 模拟赛 9

A a ⊥ b ⇒ a − b ⊥ a b (1) a \perp b \Rightarrow a-b \perp ab \tag {1} a⊥b⇒a−b⊥ab(1) 证明： gcd ⁡ ( a , b ) gcd ⁡ ( b , a − b ) \gcd(a,b) \gcd(b, a-b) gcd(a,b)gcd(b,a−b)，故 a − b ⊥ b a - b \perp b a−b⊥b，同…...

编程日记 2023/10/6 1:23:13

typescript: Builder Pattern

/*** file: CarBuilderts.ts* TypeScript 实体类 Model* Builder Pattern* 生成器是一种创建型设计模式， 使你能够分步骤创建复杂对象。* https://stackoverflow.com/questions/12827266/get-and-set-in-typescript* https://github.com/Microsoft/TypeScript/wiki/…...

编程日记 2023/10/6 1:21:10

WPS/word 表格跨行如何续表、和表的名称

1：具体操作： 将光标定位在跨页部分的第一行任意位置，按下快捷键ctrlshiftenter，就可以在跨页的表格上方插入空行（在空行可以写，表1-3 xxxx（续）） 在空行中输入…...

编程日记 2023/10/6 1:19:09

Python的NumPy库（一）基础用法

NumPy库并不是Python的标准库，但其在机器学习、大数据等很多领域有非常广泛的应用，NumPy本身就有比较多的内容，全部的学习可能涉及许多的内容，但我们在这里仅学习常见的使用，这些内容对于我们日常使用NumPy是足够的。 …...

编程日记 2023/10/6 1:13:03

uniapp app 导出excel 表格

直接复制运行 <template><view><button click"tableToExcel">导出一个表来看</button><view>{{ successTip }}</view></view> </template><script>export default {data() {return {successTip: }},metho…...

编程日记 2023/10/6 1:11:02

【RabbitMQ】常用消息模型详解

文章目录 AMQP协议的回顾RabbitMQ支持的消息模型第一种模型(直连)开发生产者开发消费者生产者、消费者开发优化API参数细节 第二种模型(work quene)开发生产者开发消费者消息自动确认机制 第三种模型(fanout)开发生产者开发消费者 第四种模型(Routing)开发生产者开发消费者 第五…...

编程日记 2023/10/6 1:08:59

图像拼接后丢失数据，转tiff报错rasterfile failed: an unknown

图像拼接后丢失数据 不仅是数据丢失了&#xff0c;还有个未知原因报错 部分数据存在值不存在的情况 原因 处理遥感数据很容易&#xff0c;磁盘爆满了 解决方案 清理一些无用数据&#xff0c;准备买个2T的外接硬盘用着了。 然后重新做处理...

编程日记 2023/10/6 0:58:47

Nginx之日志模块解读

目录 基本介绍 配置指令 access_log&#xff08;访问日志&#xff09; error_log&#xff08; 错误日志&#xff09; 基本介绍 Nginx日志主要分为两种&#xff1a;access_log(访问日志)和error_log(错误日志)。Nginx日志主要记录以下信息&#xff1a; 记录Nginx服务启动…...

编程日记 2023/10/6 0:57:46

latex方程组编写，一种可以保证方程编号自适应的方法

问题描述&#xff1a; 在利用latex编写方程组时&#xff0c;可以有很多种方法&#xff0c;但不总是编辑好的公式能够显示出编号&#xff0c;故提出一种有效的方程组编写方法 方法&#xff1a; \begin{equation}X_{ t1}\left \{ \begin{matrix}\frac{x_{i}}{a} \quad\quad 0&l…...

编程日记 2023/10/6 0:55:44

深度学习基础 2D卷积（1）

什么是2D卷积 2D参数量怎么计算 以pytorch为例子&#xff0c;2D卷积在设置的时候具有以下参数&#xff0c;具有输入通道的多少&#xff08;这个决定了卷积核的通道数量&#xff09;&#xff0c;滤波器数量&#xff0c;这个是有多少个滤波器&#xff0c;越多提取的特征就越有用…...

编程日记 2023/10/6 0:48:38

OpenCV DNN C++ 使用 YOLO 模型推理

OpenCV DNN C 使用 YOLO 模型推理 引言 YOLO&#xff08;You Only Look Once&#xff09;是一种流行的目标检测算法&#xff0c;因其速度快和准确度高而被广泛应用。OpenCV 的 DNN&#xff08;Deep Neural Networks&#xff09;模块为我们提供了一个简单易用的 API&#xff0…...

编程日记 2023/10/6 0:47:37

第八章 Linux文件系统权限

目录 8.1 文件的一般权限 1.修改文件或目录的权限---chmod命令 2.对于文件和目录&#xff0c;r&#xff0c;w&#xff0c;x有不同的作用&#xff1a; 3.修改文件或目录的所属主和组---chown,chgrp 8.2 文件和目录的特殊权限 三种通过字符描述文件权限 8.3 ACL 权限 1.A…...

编程日记 2023/10/6 0:46:36

XXL-JOB源码梳理——一文理清XXL-JOB实现方案

分布式定时任务调度系统 流程分析 一个分布式定时任务&#xff0c;需要具备有以下几点功能&#xff1a; 核心功能&#xff1a;定时调度、任务管理、可观测日志高可用&#xff1a;集群、分片、失败处理高性能&#xff1a;分布式锁扩展功能&#xff1a;可视化运维、多语言、任…...

编程日记 2023/10/6 0:45:36

java做个qq机器人

前置的条件 机器人是基于mirai框架实现的。根据官方的文档&#xff0c;建议使用openjdk11。 我这里使用的编辑工具是idea2023 在idea中新建一个maven项目&#xff0c;虽然可以使用gradle进行构建&#xff0c;不过我这里由于网络问题没有跑通。 pom.xml <dependency>&l…...

编程日记 2023/10/6 0:44:35

前端 | AjaxAxios模块

文章目录 1. Ajax1.1 Ajax介绍1.2 Ajax作用1.3 同步异步1.4 原生Ajax 2. Axios2.1 Axios下载2.2 Axios基本使用2.3 Axios方法 1. Ajax 1.1 Ajax介绍 Ajax: 全称&#xff08;Asynchronous JavaScript And XML&#xff09;&#xff0c;异步的JavaScript和XML。 1.2 Ajax作用 …...

编程日记 2023/10/6 0:43:33

高效的ProtoBuf

一、背景 Google ProtoBuf介绍 这篇文章我们讲了怎么使用ProtoBuf进行序列化&#xff0c;但ProtoBuf怎么做到最高效的&#xff0c;它的数据又是如何压缩的&#xff0c;下面先看一个例子&#xff0c;然后再讲ProtoBuf压缩机制。 二、案例 网上有各种序列化方式性能对比&#…...

编程日记 2023/10/6 0:42:33

删除SQL记录

删除记录的方式汇总&#xff1a; 根据条件删除&#xff1a;DELETE FROM tb_name [WHERE options] [ [ ORDER BY fields ] LIMIT n ] 全部删除&#xff08;表清空&#xff0c;包含自增计数器重置&#xff09;&#xff1a;TRUNCATE tb_namedelete和truncate的区别&#xff1a; d…...

编程日记 2023/10/6 0:41:30

温州市网站优化/互联网营销的方式有哪些

大家知道&#xff0c;我们的Java程序被编译器编译成class文件&#xff0c;在class文件中描述的各种信息&#xff0c;最终都需要加载到虚拟机内存才能运行和使用&#xff0c;那么虚拟机是如何加载这些class文件的呢&#xff1f;在加载class文件的过程中虚拟机又干了哪些事呢&…...

编程日记 2025/1/30 12:25:19

wordpress 博客登陆/yahoo搜索引擎提交入口

转&#xff1a;11个免费快速原型工具 Lumzy 快速原型工具 使用Lumzy你可以为你的应用创建原型图&#xff0c;还能添加一些交互事件。有了它&#xff0c;你可以创建弹出框&#xff0c;交互的页面导航&#xff0c;添加外部链接等等。他对于团队协作设计和交流提供了一个很好的平…...

编程日记 2025/1/30 11:15:21

互联网行业排行榜/seo优化技术厂家

安装 Oracle VM VitrualBoxOracle VM VirtualBox Extension PackU盘启动 VBoxManage internalcommands createrawvmdk -filename D:\usb.vmdk -rawdisk \\.\PhysicalDrive#转载于:https://www.cnblogs.com/magiclor/p/9496835.html...

编程日记 2025/1/30 11:08:03

什么是社会化网络营销方式/seo策略

最新的 C 迭代&#xff08;称为 C11&#xff0c;在去年通过了国际标准化组织 (ISO) 的审批&#xff09;形式化了一组新库和一些保留字以处理并发。 许多开发者以前都在 C 中使用过并发功能&#xff0c;但都是通过第三方的库&#xff0c;即&#xff0c;通常直接公开 OS API。 H…...

编程日记 2025/1/30 5:25:59

网站建设网站设计哪家专业/百度指数搜索热度大学

实例 41 题目 海滩上有一堆桃子&#xff0c;五只猴子来分。第一只猴子把这堆桃子凭据分为五份&#xff0c;多了 一个&#xff0c;这只猴子把多的一个扔入海中&#xff0c;拿走了一份。第二只猴子把剩下的桃子又平均分 成五份&#xff0c;又多了一个&#xff0c;它同样把多的一…...

编程日记 2025/1/30 3:16:43

网站是如何制作的/他达拉非片多少钱一盒

Apache Avro 是类似于 Google protobuf 那样的数据交换协议&#xff0c;但 Avro 可以用 JSON 格式来定义 Schema, 所以相比而言更容易上手。它也是 Hadoop, Kafka 所采用的交换格式。对于生成的 avro 序列化文件如果要编写代码来解读其中内容的话就太过于麻烦&#xff0c;Apach…...

编程日记 2025/1/30 2:55:46