kafka和zookeeper单机部署
安装kafka需要jdk和zookeeper环境,因此先部署单机zk的测试环境。
zookeeper离线安装
下载地址:
zookeeper下载地址:Index of /dist/zookeeper
这里下载安装 zookeeper-3.4.6.tar.gz 版本,测试环境单机部署
上传服务器后解压缩
tar -zxvf zookeeper-3.4.6.tar.gz
sudo mv zookeeper-3.4.6 /usr/local/zookeeper
配置conf文件
Zookeeper 在启动时会找zoo.cfg这个文件作为默认配置文件。
# 进入安装目录的…/conf目录下
cd conf/# 复制样例文件
cp zoo_sample.cfg zoo.cfg# 修改配置文件
vi zoo.cfg
# zookeeper内部的基本单位,单位是毫秒,这个表示一个tickTime为2000毫秒,在zookeeper的其他配置中,都是基于tickTime来做换算的
tickTime=2000#集群中的follower服务器(F)与leader服务器(L)之间 初始连接 时能容忍的最多心跳数(tickTime的数量)。
initLimit=10#syncLimit:集群中的follower服务器(F)与leader服务器(L)之间 请求和应答 之间能容忍的最多心跳数(tickTime的数量)
syncLimit=5# 数据存放文件夹,zookeeper运行过程中有两个数据需要存储,一个是快照数据(持久化数据)另一个是事务日志
dataDir=/data/zookeeper/data# 客户端访问端口
clientPort=2181
启动zk
# 启动服务
sh /usr/local/zookeeper/bin/zkServer.sh start# 查看服务状态
sh /usr/local/zookeeper/bin/zkServer.sh status# 测试客户端连接
sh /usr/local/zookeeper/bin/zkCli.sh
启动后查看zk状态

zookeeper参考文章:
【zookeeper安装】zookeeper安装详细教程(单机/集群部署)(linux版)-CSDN博客
zookeeper 单机版 zookeeper单机安装_蓝月亮的技术博客_51CTO博客
kafka安装
官网下载安装包
https://kafka.apache.org/downloads.html

注:kafka需要安装zookeeper使用
上传安装包解压文件:
tar -zxvf kafka_2.12-2.7.2.tgz
sudo mv kafka_2.12-2.7.2 /usr/local/kafka
修改配置文件
vim server.properties
添加或修改如下信息:#broker的全局唯一编号,不能重复broker.id=0#用来监听链接的端口,producer或consumer将在此端口建立连接listeners=PLAINTEXT://localhost:9092#kafka消息存放的路径log.dirs=/data/kafka/logs#broker需要使用zookeeper保存meta数据zookeeper.connect=localhost:2181
启动kafka
前台运行
sh bin/kafka-server-start.sh ./config/server.properties后台运行
sh bin/kafka-server-start.sh -daemon ./config/server.properties
创建topic
创建测试test的topic
sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看topic list
sh bin/kafka-topics.sh --list --zookeeper localhost:2181

生产消息
sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

消费消息
sh bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
从0开始消费所有消息
sh bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

kafka参考文章:
Kafka最全单机安装完整步骤加测试!!_kafka单机安装-CSDN博客
kafka和zookeeper安装 - 蜂蜜log - 博客园
相关文章:
kafka和zookeeper单机部署
安装kafka需要jdk和zookeeper环境,因此先部署单机zk的测试环境。 zookeeper离线安装 下载地址: zookeeper下载地址:Index of /dist/zookeeper 这里下载安装 zookeeper-3.4.6.tar.gz 版本,测试环境单机部署 上传服务器后解压缩 …...
别了,公有云!下云迁移真的是大趋势么?
【科技明说 | 科技热点关注】 不知道你们还有没有印象,早在2022年,IBM发布了《IBM 企业转型指数:云现状》中也反映了这一趋势:80%的企业已经考虑或正在考虑将已经部署到公有云上的工作负载迁回私有的基础设施。 然而&…...
网关在不同行业自动化生产线的应用
网关在不同行业自动化生产线的应用,展示了其作为信息与物理世界交汇点的广泛影响力,尤其在推动行业智能化、自动化方面发挥了不可估量的作用。以下是网关技术在污水处理、智慧农业、智慧工厂、电力改造及自动化控制等领域的深入应用剖析。 1. 污水处理 …...
C++ socket编程(1)
这里是一个socket编程Demo,不考虑出错情况,代码简单,便于了解socket流程。 Demo分为服务器程序和客户端程序,运行需要先启动服务器程序,再启动客户端程序。 服务器会等待连接,客户端连接后,服…...
C# 文件夹类的实现与文件属性处理
在现代软件开发中,处理文件和文件夹是非常常见的任务。 C# 提供了丰富的类库来操作这些文件系统的基本元素。本篇文章将探讨如何在 C# 中实现一个简单的文件夹类,以及如何获取文件名、文件路径、大小和创建日期等文件属性。 一、使用 System.IO 命…...
基于SSM框架和Layui的学院课程安排系统的设计与实现(源码+定制+定制)
博主介绍: ✌我是阿龙,一名专注于Java技术领域的程序员,全网拥有10W粉丝。作为CSDN特邀作者、博客专家、新星计划导师,我在计算机毕业设计开发方面积累了丰富的经验。同时,我也是掘金、华为云、阿里云、InfoQ等平台…...
【论文笔记】DKTNet: Dual-Key Transformer Network for small object detection
【引用格式】:Xu S, Gu J, Hua Y, et al. Dktnet: dual-key transformer network for small object detection[J]. Neurocomputing, 2023, 525: 29-41. 【网址】:https://cczuyiliu.github.io/pdf/DKTNet%20Dual-Key%20Transformer%20Network%20for%20s…...
设计模式之适配器模式(Adapter)
一、适配器模式介绍 适配器模式(adapter pattern )的原始定义是:将类的接口转换为客户期望的另一个接口, 适配器可以让不兼容的两个类一起协同工作。 适配器模式是用来做适配,它将不兼容的接口转换为可兼容的接口,让原本由于接口…...
[git] github管理项目之环境依赖管理
导出依赖到 requirements.txt pip install pipreqs pipreqs . --encodingutf8 --force但是直接使用pip安装不了torch,需要添加源!! pip install -r requirements.txt -f https://download.pytorch.org/whl/torch_stable.html想到一个麻烦的…...
【STM32 Blue Pill编程实例】-SD卡文件读写(SPI接口)
SD卡文件读写(SPI接口) 文章目录 SD卡文件读写(SPI接口)1、SD卡模块介绍2、硬件准备与接线3、模块配置3.1 SPI接口配置3.2 SPI接口的片选信号引脚配置3.3 FATFS配置4、代码实现在本文中,我们将介绍如何将 microSD 卡与 STM32 Blue Pill 连接,并在STM32CubeIDE中对SD卡进行…...
为什么需要软件测试?
软件测试 软件测试是评估和验证计算机程序或系统是否按预期运行的过程。 它涉及执行程序或系统以识别预期结果和实际结果之间的任何错误或差距。 目标是确保软件满足指定的要求,没有缺陷,并在不同场景中可靠地工作。 为什么需要软件测试?…...
成为超人:普通人如何白手起家,富一代和富二代的根本区别是什么?
成为超人:普通人如何白手起家,富一代和富二代的根本区别是什么? 我的问题是事业就讲 10 年装逼学习法失效① 光说不练,还是太懒真正的勤奋,解决温饱后,只专注赚钱这件事 ② 信念飘摇,随波流转万…...
Java 集合 Collection常考面试题
理解集合体系图 collection中 list 是有序的,set 是无序的 什么是迭代器 主要遍历 Collection 集合中的元素,所有实现了 Collection 的集合类都有一个iterator()方法,可以返回一个 iterator 的迭代器。 ArrayList 和 Vector 的区别? ArrayList 可以存放 null,底层是由数…...
C++继承与菱形继承(一文了解全部继承相关基础知识和面试点!)
目的减少重复代码冗余 Class 子类(派生类) : 继承方式 父类(基类) 继承方式共有三种:公共、保护、私有 父类的私有成员private无论哪种继承方式都不可以被子类使用 保护protected权限的内容在类内是可以访问,但是在…...
谷歌DeepMind 德米斯·哈萨比斯 因蛋白质预测AI荣获诺贝尔化学奖
2024年诺贝尔化学奖的一半授予了谷歌DeepMind的联合创始人兼首席执行官德米斯哈萨比斯和公司总监约翰M朱姆珀,以表彰他们在利用人工智能预测蛋白质结构方面的研究成果。另一半奖项则授予华盛顿大学生物化学教授大卫贝克,以表彰他在计算蛋白质设计领域的贡…...
内网笔记大全
内网笔记大全 1、基础命令 Windows 1、net user #查看用户 2、net view #查看在线主机 3、systeminfo #查看操作系统的基本配置 4、ipconfig /all #详细显示当前网络配置信息和网卡信息 5、net localgroup #查看本地组信息 6、net localgroup administrators #查看管理员组 7、…...
peft.LoraConfig()参数说明
LoraConfig()介绍 LoraConfig()是peft库中的一个配置类,用于设置大模型微调方法LoRA(Low-Rank Adaptation)的相关参数。PEFT 库为各种参数高效的微调方法(如 LoRA)提供了封装,以减少微调大模型时的计算资源…...
串口(UART)的FPGA设计(接收与发送模块)
目录 串口基础知识 一、什么是串口?有哪些特点? 二、常见的串口通信协议有哪些?他们有什么区别?...
JSON 格式化工具:快速便捷地格式化和查看 JSON 数据
JSON 格式化工具:快速便捷地格式化和查看 JSON 数据 为什么需要 JSON 格式化工具? 在日常开发和调试中,JSON 是非常常见的数据交换格式。无论是前端与后端的接口调用,还是数据存储和处理,JSON 格式都扮演着重要角色。…...
【星汇极客】STM32 HAL库各种模块开发之1.8TFT屏幕
前言 本人是一名嵌入式学习者,在大学期间也参加了不少的竞赛并获奖,包括:江苏省电子设计竞赛省一、睿抗机器人国二、中国高校智能机器人国二、嵌入式设计竞赛国三、光电设计竞赛国三、节能减排竞赛国三等。 暑假的时候参加了太多的比赛&#…...
告别虚拟机!Win11上保姆级配置Kali Linux子系统,附图形化界面与阿里云源教程
Win11极致轻量化Kali Linux子系统实战:从零构建渗透测试工作站 如果你是一名安全研究员、渗透测试工程师,或者只是对网络安全充满好奇的技术爱好者,那么Kali Linux一定不会陌生。但传统虚拟机方案带来的性能损耗和资源占用,常常让…...
Nanbeige 4.1-3B部署教程:阿里云GPU实例一键部署像素冒险聊天终端
Nanbeige 4.1-3B部署教程:阿里云GPU实例一键部署像素冒险聊天终端 1. 项目介绍 Nanbeige 4.1-3B像素冒险聊天终端是一款专为Nanbeige大模型设计的游戏风格对话界面。它将传统AI对话体验转变为一场视觉化的冒险旅程,特别适合游戏开发者和创意工作者使用…...
五种新鲜与腐烂果蔬识别分割数据集labelme格式1131张5类别
注意数据集中有部分增强图片数据集格式:labelme格式(不包含mask文件,仅仅包含jpg图片和对应的json文件)图片数量(jpg文件个数):1131标注数量(json文件个数):1131标注类别数:10标注类别名称:["fresh_apple",&…...
Qwen2.5-VL-7B-Instruct实战教程:16GB显存GPU上快速部署图文对话系统
Qwen2.5-VL-7B-Instruct实战教程:16GB显存GPU上快速部署图文对话系统 1. 教程概述 Qwen2.5-VL-7B-Instruct是一款强大的多模态视觉-语言模型,能够理解图片内容并进行智能对话。本教程将带你在16GB显存的GPU上快速部署这个图文对话系统,让你…...
RTOS裁剪性能测试终极清单(含Keil/IAR/GCC三编译器差异对照表、LPC55S69实机跑分数据、MISRA-C合规性checklist):错过=项目延期风险+30%
第一章:RTOS裁剪性能测试的工程价值与风险量化模型RTOS裁剪并非简单的功能删减,而是面向具体硬件资源约束与实时性边界条件的系统级权衡决策。其工程价值体现在三重维度:内存占用降低直接提升嵌入式设备量产良率;中断响应时间缩短…...
Qwen3-32B-Chat效果对比:不同FlashAttention版本对RTX4090D推理性能影响
Qwen3-32B-Chat效果对比:不同FlashAttention版本对RTX4090D推理性能影响 1. 测试环境与配置 1.1 硬件配置 本次测试使用以下硬件环境: 显卡:NVIDIA RTX 4090D 24GB显存内存:128GB DDR5CPU:Intel i9-13900K (10核心…...
Hunyuan-MT-7B从零开始:新手也能掌握的开源翻译模型调用指南
Hunyuan-MT-7B从零开始:新手也能掌握的开源翻译模型调用指南 1. 引言:为什么选择Hunyuan-MT-7B? 你是否曾经遇到过需要翻译外文资料,但机器翻译结果生硬不自然的情况?或者需要处理小众语言的翻译,但主流翻…...
摒弃有害厨具,京尚黑科技陶瓷锅,开启高端健康烹饪时代
健康生活,从选对一口锅开始。京尚纯陶瓷锅以天然无机材质为核心,坚守“零重金属、零有害析出”的安全底线,不含锰、铅、镉,不生锈、不串味、不腐蚀,完美替代有健康隐患的不锈钢与涂层锅,让烹饪回归纯粹与安…...
老周虾扯:AI 记忆机制工程实践
前言 上一篇我们理论讲完了,现在动手实践实践。毕竟“纸上得来终觉浅,绝知此事要躬行。” 本文聚焦工程落地:从最简单的 Buffer Memory 到生产级的向量记忆、图记忆,一步步带你把 AI 记忆真正跑起来。所有代码均可直接运行。一、最…...
如何快速突破微信网页版限制:wechat-need-web完整解决方案指南
如何快速突破微信网页版限制:wechat-need-web完整解决方案指南 【免费下载链接】wechat-need-web 让微信网页版可用 / Allow the use of WeChat via webpage access 项目地址: https://gitcode.com/gh_mirrors/we/wechat-need-web 在远程办公和跨平台协作日益…...
