容器化部署Kafka的最佳实践：基于KRaft模式的无ZooKeeper方案
一、docker 部署kafka单节点
1.1安装docker
可以参考这篇CentOS 7安装docker并配置镜像加速
1.3 运行kafka（注意修改zookeeper，kafka地址）
docker run -d --name kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.16.10.180:9092 -p 9092:9092 -v /home/application/Middleware/kafka/data:/var/lib/kafka/data --restart=always docker.cnb.cool/srebro/docker-images/kafka-kraft:3.7.2
1.4 登录kafka容器，创建topic
docker exec -it kafka bash
cd /opt/kafka/bin./kafka-topics.sh --create --topic my_topic_srebro.cn --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
1.5 登录kafka容器，启动一个生产者
docker exec -it kafka bash
cd /opt/kafka/bin./kafka-console-producer.sh --topic my_topic_srebro.cn --bootstrap-server localhost:9092
1.6 新开一个终端窗口，登录kafka容器，启动一个消费者
docker exec -it kafka bash
cd /opt/kafka/bin./kafka-console-consumer.sh --topic my_topic_srebro.cn --bootstrap-server localhost:9092 --from-beginning1.7 模拟在生产者上，测试几条数据，观察消费者上有没有收到数据
1.8 kafka map 管理工具
A beautiful, concise and powerful kafka web management tool. 一个美观简洁且强大的kafka web管理工具。
- 官方帮助手册： https://github.com/dushixiang/kafka-map/blob/master/README-zh_CN.md
docker run -d \-p 8080:8080 \-v /opt/kafka-map/data:/usr/local/kafka-map/data \-e DEFAULT_USERNAME=admin \-e DEFAULT_PASSWORD=admin \--name kafka-map \--restart always dushixiang/kafka-map:latest
二、docker-compose 部署kafka单节点
2.1 安装docker-compose
可以参考这篇Cenotos7 安装docker-compose
2.2 编排docker-compose文件
注意先要创建docker 单独的网络
创建自定义网络 ： docker network create -d bridge --subnet “192.168.10.0/24” --gateway “192.168.10.1” srebro.cn
version: '3'services:kafka:image: docker.cnb.cool/srebro/docker-images/kafka-kraft:3.7.2container_name: kafkanetworks:- srebro.cnenvironment:#KAFKA_LISTENERS: PLAINTEXT://:9092 # Kafka 监听端口配置KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://172.16.10.180:9092 # Kafka 对外公布的地址#KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT # 监听器与安全协议的映射#KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT # Broker 间通信使用的监听器ports:- "9092:9092"volumes:- /home/application/Middleware/kafka/data:/var/lib/kafka/datarestart: alwayskafka-map: #image: dushixiang/kafka-map:latestimage: docker.cnb.cool/srebro/docker-images/dushixiang-kafka-map:latest #加速地址container_name: kafka-mapnetworks:- srebro.cnvolumes:- "/home/application/Middleware/kafka/kafka-map/data:/usr/local/kafka-map/data" ports:- 19006:8080environment:DEFAULT_USERNAME: adminDEFAULT_PASSWORD: 123456depends_on:- kafkarestart: 'unless-stopped'networks:srebro.cn:external: true
相关文章：
容器化部署Kafka的最佳实践：基于KRaft模式的无ZooKeeper方案
一、docker 部署kafka单节点 1.1安装docker 可以参考这篇CentOS 7安装docker并配置镜像加速 1.3 运行kafka（注意修改zookeeper，kafka地址） docker run -d --name kafka -e KAFKA_ADVERTISED_LISTENERSPLAINTEXT://172.16.10.180:9092 -p …...
20250214 随笔 线程安全 线程不安全
1. 什么是线程安全 & 线程不安全？ 线程安全（Thread-Safe）：在多线程环境下访问同一个对象时，不会产生数据竞争、不会出现数据不一致的问题。线程不安全（Not Thread-Safe）：在多线…...
rem、em、vw区别
在前端开发里，rem、em、vw都是用来设置元素大小的单位，下面就用大白话讲讲它们的区别。 参考标准不一样 rem：就像大家都用同一把“大尺子”来量东西，这把“大尺子”就是网页里根元素（也就是 <html> 标签&#…...
【PHP】php+mysql 活动信息管理系统（源码+论文+数据库+数据库文件）【独一无二】
👉博__主👈：米码收割机 👉技__能👈：C/Python语言 👉专__注👈：专注主流机器人、人工智能等相关领域的开发、测试技术。 【PHP】php 活动信息管理系统（源码论文…...
cURL请求与Javascript请求转换工具
cURL请求与Javascript请求在线转换工具（如 curlconverter） 首先，看看各个证据中关于curl的定义。提到cURL是“Client for URLs”的缩写，最初全大写是为了方便记忆，社区也将其解释为“Client URL Request Library”或递归的“Curl URL Request Library”。同时，还指出cURL…...
rv1103b编译opencv
opencv-3.4.16，png的neon会报错，如果想开可以参考 https://blog.csdn.net/m0_60827485/article/details/137561429 rm -rf build mkdir build cd build cmake -DCMAKE_BUILD_TYPERELEASE \ -DCMAKE_C_COMPILERxxx/arm-rockchip831-linux-uclibcgnueabih…...
thingboard告警信息格式美化
原始报警json内容： { "severity": "CRITICAL","acknowledged": false,"cleared": false,"assigneeId": null,"startTs": 1739801102349,"endTs": 1739801102349,"ackTs": 0,&quo…...
OpenHarmonry 5.0.1源码下载与编译
预置环境：硬盘500G、内存32G、Ubuntu 20.04.6 LTS Ubuntu系统下载路径：ubuntu-releases安装包下载_开源镜像站-阿里云 一、必需环境 sudo apt-get update && sudo apt-get install binutils binutils-dev git git-lfs gnupg flex bison gperf…...
【Python深入浅出㊸】解锁Python3中的TensorFlow：开启深度学习之旅
目录 一、TensorFlow 简介1.1 定义与背景1.2 特点 二、Python 3 与 TensorFlow 的关系2.1 版本对应2.2 为何选择 Python 3 三、安装 TensorFlow3.1 安装步骤3.2 验证安装 四、TensorFlow 基本概念与使用方法4.1 计算图（Graph）4.2 会话（Sessio…...
STM32 外部中断和NVIC嵌套中断向量控制器
目录 背景 外部中断/事件控制器(EXTI) 主要特性 功能说明 外部中断线 嵌套向量中断控制器 特性 中断线（Interrupt Line） 中断线的定义和作用 STM32中断线的分类和数量 优先级分组 抢占优先级（Preemption Priority） …...
string类详解（上）
文章目录 目录1. STL简介1.1 什么是STL1.2 STL的版本1.3 STL的六大组件 2. 为什么学习string类3. 标准库中的string类3.1 string类3.2 string类的常用接口说明 目录 STL简介为什么学习string类标准库中的string类string类的模拟实现现代版写法的String类写时拷贝 1. STL简介 …...
DeepSeek教unity------Dotween
1、命名法 Tweener（补间器）：一种控制某个值并对其进行动画处理的补间。 Sequence（序列）：一种特殊的补间，它不直接控制某个值，而是控制其他补间并将它们作为一个组进行动画处理。 Tw…...
AIP-146 泛化域
编号146原文链接AIP-146: Generic fields状态批准创建日期2019-05-28更新日期2019-05-28 API中的大多数域，无论是在请求、资源还是自定义应答中，都有具体的类型或模式。这个模式是约定的一部分，开发者依此约定进行编码。 然而，偶…...
【Go并发编程】Goroutine 调度器揭秘：从 GMP 模型到 Work Stealing 算法
每天一篇Go语言干货，从核心到百万并发实战，快来关注魔法小匠，一起探索Go语言的无限可能！ 在 Go 语言中，Goroutine 是一种轻量级的并发执行单元，它使得并发编程变得简单高效。而 Goroutine 的高效调度机制是…...
【前端】Vue组件库之Element: 一个现代化的 UI 组件库
文章目录 前言一、官网1、官网主页2、设计原则3、导航4、组件 二、核心功能：开箱即用的组件生态1、丰富的组件体系2、特色功能亮点 三、快速上手：三步开启组件化开发1、安装（使用Vue 3）2、全局引入3、按需导入（推荐&am…...
第十五天 学习并实践HarmonyOS应用的基本结构、页面导航和状态管理
HarmonyOS应用开发入门：从基本结构到状态管理实战指南 前言 （约300字，说明HarmonyOS的发展前景，应用开发的市场需求，以及本教程的核心价值。强调手把手教学特点，降低学习门槛） 一、HarmonyOS应…...
Cursor生成JAVA相关的关键词提示规则
在项目根目录创建一个.curstorrules文件（注意有个小数点），之后在该文件内填入下面内容 你是 Java 编程、Spring Boot、Spring Framework、Maven、JUnit 及相关 Java 技术的专家。 代码风格与结构 编写整洁、高效且文档完善的 Java 代码&am…...
数据结构：队列（Queue）及其实现
队列（Queue）是一种广泛使用的线性数据结构，它遵循先进先出（FIFO，First In, First Out）的原则。也就是说，最早插入队列的元素会最先被移除。队列是一种典型的顺序存取结构，它与栈&…...
MoE架构中的专家选择门控机制：稀疏激活如何实现百倍效率突破？
技术原理（数学公式与核心逻辑） 核心公式 门控网络输出： G ( x ) Softmax ( W g ⋅ x b g ) G(x) \text{Softmax}(W_g \cdot x b_g) G(x)Softmax(Wg⋅xbg) 最终输出： y ∑ i 1 n G i ( x ) ⋅ E i ( x ) (仅保留Top-…...
坐井说天阔---DeepSeek-R1
前言 DeepSeek-R1这么火，虽然网上很多介绍和解读，但听人家的总不如自己去看看原论文。于是花了大概一周的时间，下班后有进入了研究生的状态---读论文。 DeepSeek这次的目标是探索在没有任何监督数据的情况下训练具有推理能力的大模型&#…...
UART（一）——UART基础
一、定义 UART（Universal Asynchronous Receiver/Transmitter）是一种广泛使用的串行通信协议，用于在设备间通过异步方式传输数据。它无需共享时钟信号，而是依赖双方预先约定的参数（如波特率）完成通信。 功能和特点 基本的 UART 系统只需三个信号即可提供稳健的中速全双工…...
DeepSeek 的创新融合：多行业应用实践探索
引言 在数字化转型的浪潮中，技术的融合与创新成为推动各行业发展的关键力量。蓝耘平台作为行业内备受瞩目的创新平台，以其强大的资源整合能力和灵活的架构，为企业提供了高效的服务支持。而 DeepSeek 凭借先进的人工智能技术，在自然…...
C语言中的常量与只读变量，#define与const的区别
#include中的#表明C处理器需要在编译器接手工作之前先处理这条指令。 #define 这条定义宏的语句，是不是很熟悉，这条预处理指令会在编译器编译前把源文件中使用到这个宏的地方都先展开。 #define NUM 12 这个定义了一个宏常量，它的处理发生编…...
Python常见面试题的详解6
1. 按字典 value 值排序 要点：对于给定字典，使用 sorted() 函数结合 items() 方法，依据 value 进行排序，也可以定义一个通用函数，支持按 value 升序或降序排序。示例： python d {a: 1, b: 2, c: 3, d: …...
CentOS 7超详细安装教程（含镜像）
1. 安装前准备 1.1 CentOS简介 CentOS（Community Enterprise Operating System，中文意思是：社区企业操作系统）是一种基于 Red Hat Enterprise Linux（RHEL）源代码构建的免费开源操作系统。它在稳定性、安全…...
代码随想录day12
144.二叉树的前序遍历 //明确递归的函数，结束边界，单层逻辑 void traversal(TreeNode* node, vector<int>& list){if(node nullptr){return;}list.push_back(node->val);traversal(node->left, list);traversal(node->right, list)…...
langchain学习笔记之消息存储在内存中的实现方法
langchain学习笔记之消息存储在内存中的实现方法 引言背景消息存储在内存的实现方法消息完整存储：完整代码 引言 本节将介绍 langchain \text{langchain} langchain将历史消息存储在内存中的实现方法。 背景 在与大模型交互过程中，经常出现消息管理方…...
布隆过滤器（简单介绍）
布隆过滤器（Bloom Filter） 是一种高效的概率型数据结构，用于快速判断一个元素是否可能存在于某个集合中。它的核心特点是空间效率极高，但存在一定的误判率（可能误报存在，但不会漏报）。 核心原理…...
Qt中基于开源库QRencode生成二维码(附工程源码链接)
目录 1.QRencode简介 2.编译qrencode 3.在Qt中直接使用QRencode源码 3.1.添加源码 3.2.用字符串生成二维码 3.3.用二进制数据生成二维码 3.4.界面设计 3.5.效果展示 4.注意事项 5.源码下载 1.QRencode简介 QRencode是一个开源的库，专门用于生成二维码&…...
SpringBoot教程（三十二） SpringBoot集成Skywalking链路跟踪
SpringBoot教程（三十二） | SpringBoot集成Skywalking链路跟踪 一、Skywalking是什么？二、Skywalking与JDK版本的对应关系三、Skywalking下载四、Skywalking 数据存储五、Skywalking 的启动六、部署探针 前提： Agents 8.9.0 放入 …...