kafka-集群搭建（在docker中搭建）
文章目录
- 1、kafka集群搭建
- 1.1、下载镜像文件
- 1.2、创建zookeeper容器并运行
- 1.3、创建3个kafka容器并运行
- 1.3.1、9095端口
- 1.3.2、9096端口
- 1.3.3、9097端口
- 1.4、重启kafka-eagle
- 1.5、查看 efak
- 1.5.1、查看 brokers
- 1.5.2、查看 zookeeper
1、kafka集群搭建
1.1、下载镜像文件
docker pull bitnami/zookeeper
docker pull bitnami/kafka
1.2、创建zookeeper容器并运行
docker run -d --name kafka-zk -p 2181:2181 -e ALLOW_ANONYMOUS_LOGIN=yes bitnami/zookeeper
1.3、创建3个kafka容器并运行
1.3.1、9095端口
docker run -d --name kafka-01 -p 9095:9095 -e KAFKA_BROKER_ID=95 -e KAFKA_ZOOKEEPER_CONNECT=192.168.74.148:2181 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.74.148:9095 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT,SASL_EXTERNAL:SASL_PLAINTEXT,SASL_INTERNAL:SASL_PLAINTEXT,SASL_SSL_EXTERNAL:SASL_SSL,SASL_SSL_INTERNAL:SASL_SSL,SSL_INTERNAL:SSL,SSL_EXTERNAL:SSL -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9095 -e KAFKA_MESSAGE_MAX_BYTES=1000000 bitnami/kafka
1.3.2、9096端口
docker run -d --name kafka-02 -p 9096:9096 -e KAFKA_BROKER_ID=96 -e KAFKA_ZOOKEEPER_CONNECT=192.168.74.148:2181 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.74.148:9096 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT,SASL_EXTERNAL:SASL_PLAINTEXT,SASL_INTERNAL:SASL_PLAINTEXT,SASL_SSL_EXTERNAL:SASL_SSL,SASL_SSL_INTERNAL:SASL_SSL,SSL_INTERNAL:SSL,SSL_EXTERNAL:SSL -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9096 -e KAFKA_MESSAGE_MAX_BYTES=1000000 bitnami/kafka
1.3.3、9097端口
docker run -d --name kafka-03 -p 9097:9097 -e KAFKA_BROKER_ID=97 -e KAFKA_ZOOKEEPER_CONNECT=192.168.74.148:2181 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.74.148:9097 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT,SASL_EXTERNAL:SASL_PLAINTEXT,SASL_INTERNAL:SASL_PLAINTEXT,SASL_SSL_EXTERNAL:SASL_SSL,SASL_SSL_INTERNAL:SASL_SSL,SSL_INTERNAL:SSL,SSL_EXTERNAL:SSL -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9097 -e KAFKA_MESSAGE_MAX_BYTES=1000000 bitnami/kafka
1.4、重启kafka-eagle
[root@localhost ~]# docker restart kafka-eagle
kafka-eagle
1.5、查看 efak
1.5.1、查看 brokers
1.5.2、查看 zookeeper
相关文章：
kafka-集群搭建（在docker中搭建）
文章目录 1、kafka集群搭建1.1、下载镜像文件1.2、创建zookeeper容器并运行1.3、创建3个kafka容器并运行1.3.1、9095端口1.3.2、9096端口1.3.3、9097端口 1.4、重启kafka-eagle1.5、查看 efak1.5.1、查看 brokers1.5.2、查看 zookeeper 1、kafka集群搭建 1.1、下载镜像文件 d…...
特征交叉系列：DCN-Mix 混合低秩交叉网络理论和实践
DCN-Mix和DCN-V2的关系 DCN-Mix(a mixture of low-rank DCN)是基于DCN-V2的改进版，它提出使用矩阵分解来降低DCN-V2的时间空间复杂度，又引入多次矩阵分解来达到类似混合专家网络MOE的效果从而提升交叉层的表征能力，若读者对DCN-V2不甚了解可…...
python项目(豆瓣电影)
目录 1、项目效果 2、项目源码 3、技术实现 4、总结 前言 我的这个项目是做的一个豆瓣电影爬取，爬取了豆瓣电影的TOP排行榜的数据 包括电影的名称 演员 评分 评价人数等等 运用了TK布局助手 布了4个界面 有登录 注册 首页 详情 注意：项目并没有连接数…...
精选网络安全书单：打造数字世界的钢铁长城！
目录 1.前言 2.书单推荐 2.1. 《内网渗透实战攻略》 2.2. 《Kali Linux高级渗透测试（原书第4版）》 2.3. 《CTF那些事儿》 2.4. 《权限提升技术：攻防实战与技巧》 2.5. 《数字政府网络安全合规性建设指南：密码应用与数据安全…...
Ubuntu由于没有公钥，无法验证下列签名。
其他操作系统报错也一样处理，我kali的也是这样解决的。 使用sudo apt update时出现以下错误： 3B4FE6ACC0B21F32就是公钥，每个人的不一样，注意看自己的报错信息 :~$ sudo apt update [sudo] ts 的密码： 命中:1 http:…...
水库安全监测系统：智慧水文动态监测系统
TH-SW2水库安全监测系统，作为一款智慧水文动态监测系统，其在现代水利管理中扮演着至关重要的角色。该系统通过集成先进的数据采集、传输、处理和分析技术，为水库的安全运行提供了强有力的技术支撑。 水库安全监测系统是一种用于实时监测和记…...
下载centos7镜像及在VMware上安装Linux (Centos7)操作系统详细教程
文章目录 下载centos7镜像文件及在VMware上安装centos7详细教程一、下载Centos7镜像二、 利用VM安装Centos7进入VM软件安装配置虚拟机 安装Centos7进入图形化界面配置 三、访问外网 配置IP地址结语Linux配置IP网卡Linux配置本地yum源 下载centos7镜像文件及在VMware上安装cento…...
【全开源】考试答题系统源码（FastAdmin+ThinkPHP+Uniapp）
一款基于FastAdminThinkPHPUniapp开发的小程序答题考试系统，提供全部前后台无加密源代码，支持私有化部署。 📝考试答题系统：便捷高效的学习新选择💡 📚 考试答题系统是什么？ 考试答题系统&…...
toB市场 | 我们喜欢赞助这样的展会活动
过去的六一儿童节，刚去成都参加了个行业内的展会。受护网行动、儿童节等等的影响，这次去成都的客户并不算太多，但会议延续了一贯的高品质，让我们收货满满。 选择目标受众来得多的展会 不同厂商会视自己的产品和模式、目标客户来…...
【学习笔记】Git常用命令
目录 Git常用命令1. git init （初始化一个新的Git仓库）2. git clone [url] （克隆远程仓库到本地计算机）3. git status （查看当前工作区的状态）4. git add [file] （将文件添加到暂存区࿰…...
【C/C++】IO流
目录 前言： 一，C语言的I/O流 二，C的I/O流 2-1，C标准IO流 2-2，IO流的连续输入 前言： “流”即是流动的意思，是物质从一处向另一处流动的过程，是对一种有序连续且具有方向性的数据…...
Vite5+Vue3整合Tailwindcss详细教程
创建vite项目 执行命令： npm create vite启动项目 npm install -g pnpm pnpm i pnpm dev浏览器访问 http://localhost:5174/ 整合Tailwindcss 安装依赖 pnpm install -D tailwindcss postcss autoprefixer初始化配置文件 npx tailwindcss init用webstorm打开…...
小程序 UI 风格魅力非凡
小程序 UI 风格魅力非凡...
【常用工具系列】Git 教程——从入门到大师
目录 前言一、Git 基础1-1、Git 简介与安装安装 Git 1-2、 Git 工作流程1-3、 Git 配置与管理用户配置查看配置 1-4、 Git 仓库操作克隆仓库推送更改拉取更新 1-5 Git 分支管理创建分支切换分支删除分支解决冲突 二、 Git 进阶2-0、 Git 标签使用创建标签查看标签检出标签推送标…...
每天坚持写java锻炼能力---第一天(6.4)
今天的目标是菜单： B站/马士兵的项目菜单 package java1;import java.util.Scanner;public class Test {public static void main(String[] args) {while(true){ //3.加入死循环，让输入一直有System.out.println();System.out.println("--->项…...
mysql 如何分布式部署
MySQL的分布式部署是一个涉及多个步骤和配置的过程，以确保数据库系统能够支持大规模数据存储、高并发访问和容错性。以下是MySQL分布式部署的主要步骤和要点，结合参考文章中的相关信息进行整理： 一、前期准备 环境准备： 选择合…...
Git的概念
Git 一些概念 **工作区：**电脑上你能看到的目录 **版本库：**工作区的隐藏目录.git。含 暂存区：git add后但未git commit的文件修改被添加到暂存区本地分支：git commit后，但未git push，即把暂存区的所有…...
【每日刷题】Day58
【每日刷题】Day58 🥕个人主页：开敲🍉 🔥所属专栏：每日刷题🍍 🌼文章目录🌼 1. 3038. 相同分数的最大操作数目 I - 力扣（LeetCode） 2. 868. …...
Python 的七个HTTP请求库对比
Python HTTP请求库对比 库名称特点优点缺点requests简单易用的HTTP库，基于urllib3。- 语法简洁- 社区支持强大- 易于上手和维护- 阻塞式调用，不支持异步操作- 相比aiohttp体积较大http.clientPython标准库中的低级HTTP库。- 无需安装第三方库- 提供底层…...
顶顶通呼叫中心中间件-如何配置识别不同语种的ASR
文章目录 前言联系我们创建不同语种的语音识别任务开始对接识别不同语种的ASR重启 asrproxy 程序使用识别不同语种的ASR 前言 之前讲过顶顶通的 asrproxy 程序如何对接第三方的ASR，比如：阿里云的ASR。不知道如何对接的，可以参考：…...
UE5 学习系列（二）用户操作界面及介绍
这篇博客是 UE5 学习系列博客的第二篇，在第一篇的基础上展开这篇内容。博客参考的 B 站视频资料和第一篇的链接如下： 【Note】：如果你已经完成安装等操作，可以只执行第一篇博客中 2. 新建一个空白游戏项目 章节操作，重…...
【OSG学习笔记】Day 18: 碰撞检测与物理交互
物理引擎（Physics Engine） 物理引擎 是一种通过计算机模拟物理规律（如力学、碰撞、重力、流体动力学等）的软件工具或库。 它的核心目标是在虚拟环境中逼真地模拟物体的运动和交互，广泛应用于 游戏开发、动画制作、虚…...
UDP(Echoserver)
网络命令 Ping 命令 检测网络是否连通 使用方法: ping -c 次数 网址ping -c 3 www.baidu.comnetstat 命令 netstat 是一个用来查看网络状态的重要工具. 语法：netstat [选项] 功能：查看网络状态 常用选项： n 拒绝显示别名&#…...
Leetcode 3577. Count the Number of Computer Unlocking Permutations
Leetcode 3577. Count the Number of Computer Unlocking Permutations 1. 解题思路2. 代码实现 题目链接：3577. Count the Number of Computer Unlocking Permutations 1. 解题思路 这一题其实就是一个脑筋急转弯，要想要能够将所有的电脑解锁&#x…...
基于Uniapp开发HarmonyOS 5.0旅游应用技术实践
一、技术选型背景 1.跨平台优势 Uniapp采用Vue.js框架，支持"一次开发，多端部署"，可同步生成HarmonyOS、iOS、Android等多平台应用。 2.鸿蒙特性融合 HarmonyOS 5.0的分布式能力与原子化服务，为旅游应用带来…...
算法：模拟
1.替换所有的问号 1576. 替换所有的问号 - 力扣（LeetCode） 遍历字符串：通过外层循环逐一检查每个字符。遇到 ? 时处理： 内层循环遍历小写字母（a 到 z）。对每个字母检查是否满足： 与…...
解决：Android studio 编译后报错\app\src\main\cpp\CMakeLists.txt‘ to exist
现象： android studio报错： [CXX1409] D:\GitLab\xxxxx\app.cxx\Debug\3f3w4y1i\arm64-v8a\android_gradle_build.json : expected buildFiles file ‘D:\GitLab\xxxxx\app\src\main\cpp\CMakeLists.txt’ to exist 解决： 不要动CMakeLists.…...
MySQL的pymysql操作
本章是MySQL的最后一章，MySQL到此完结，下一站Hadoop！！！ 这章很简单，完整代码在最后，详细讲解之前python课程里面也有，感兴趣的可以往前找一下 一、查询操作 我们需要打开pycharm …...
Spring Boot + MyBatis 集成支付宝支付流程
Spring Boot MyBatis 集成支付宝支付流程 核心流程 商户系统生成订单调用支付宝创建预支付订单用户跳转支付宝完成支付支付宝异步通知支付结果商户处理支付结果更新订单状态支付宝同步跳转回商户页面 代码实现示例（电脑网站支付） 1. 添加依赖 <!…...
 ——通用对象池总结(核心))
怎么开发一个网络协议模块（C语言框架）之(六) ——通用对象池总结(核心)
+---------------------------+ | operEntryTbl[] | ← 操作对象池 (对象数组) +---------------------------+ | 0 | 1 | 2 | ... | N-1 | +---------------------------+↓ 初始化时全部加入 +------------------------+ +-------------------------+ | …...