Kafka本地安装⭐️(Windows)并测试生产消息以及消费消息的可用性

2023.12.17        天气晴      温度较低

  • 十点半,不是不想起实在是阳光浴太nice了
  • 日常三连,喂,刷,肝
  • 刷会儿博客,看会儿设计模式
  • 冷冷冷 进被窝 刷视频 睡觉
  • 看看kafka的本地部署 》》实践》》成功
  • 写会儿博客,45俯卧撑,洗洗睡了,明天上班

一、 kafka简介

        Kafka 是一个分布式的流处理平台,由 LinkedIn 公司开发。它是一种高吞吐量、低延迟的消息传递系统,主要用于处理实时数据流和日志数据。Kafka 是一个基于发布-订阅(publish-subscribe)的模型,通过将消息存储在不同的 topic(主题)中,允许多个消费者并行地消费数据。

主要特点包括:

  1. 高性能:Kafka 能够处理数百万条消息的每秒读写速度,同时保证数据的持久化存储和高可靠性。

  2. 可扩展性:Kafka 是一个分布式系统,可以方便地扩展到数以千计的节点,以满足业务需求的快速增长。

  3. 容错性:Kafka 能够自动进行数据备份和故障转移,保证数据的不丢失和可用性。

  4. 多语言支持:Kafka 有多种编程语言的客户端库,支持多种编程语言的开发人员进行开发和集成。

  5. 灵活性:Kafka 提供了多种配置选项,用户可以根据自己的需求进行灵活配置。

二、本地部署(Windows  x64)

 2.1 安装包下载/官网下载

链接:https://pan.baidu.com/s/1Ic2DQ1hdt3DKiQh9mN27Og 
提取码:hunb

2.2 解压,我这里解压到D盘SoftWare文件夹下

2.3 启用zookeeper(简单使用自带的即可)
        2.3.1 命令窗口1,输入cmd 回车 从当前路径进入命令页,输入以下命令 回车,如图启动成功

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

2.4 启动kafka(依赖zookeeper,必须先启动成功)

        命令窗口2,跟命令窗口1的打开方式相同,找到层目录输入cmd即可,输入以下命令,回车,如下图启动成功

.\bin\windows\kafka-server-start.bat .\config\server.properties

三、测试kafka(前两个命令页面不可以关闭,需要保持服务开启)

        3.1  命令页面3

        创建名为“topic_test001”的主题,命令页面的打开方式与之前相同,输入命令,回车,等待下出现如下标识,代表创建成功

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test001

----------------------------------------创建主题命令详解---------------------------------------------------------

.\bin\windows\kafka-topics.bat:这是执行 Kafka 主题管理工具的命令。

--create:这是一个选项,表示要创建一个新的主题。

--zookeeper localhost:2181:这是指定 ZooKeeper 的地址和端口,用于管理 Kafka 集群的元数据信息。

--replication-factor 1:这是指定每个分区的副本数量。在这里,指定为 1,表示每个分区只有一个副本。

--partitions 1:这是指定主题的分区数量。在这里,指定为 1,表示只创建一个分区。

--topic topic_test001:这是指定要创建的主题的名称。

        先创建生产者来生产测试消息,在命令3页面紧接着输入以下命令回车,等待下出现“>"标识说明后面的输入内容都是作为消息内容

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topic_test001

--------------------------------------------发送消息命令详解----------------------------------------------------

.\bin\windows\kafka-console-producer.bat:这是执行 Kafka 控制台生产者的命令。

--broker-list localhost:9092:这是指定 Kafka broker 的地址和端口,用于连接到 Kafka 集群。

--topic topic_test001:这是指定要发送消息的主题名称

 3.2 命令页面4

        创建一个消费者来接收生产消息,命令页面打开方式与之前一样,输入以下命令,如图成功接收到生产消息

 .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic_test001 --from-beginning

-----------------------------------------消费消息命令详解--------------------------------------------------

.\bin\windows\kafka-console-consumer.bat:这是执行 Kafka 控制台消费者的命令。

--bootstrap-server localhost:9092:这是指定 Kafka broker 的地址和端口,用于连接到 Kafka 集群。

--topic topic_test001:这是指定要消费的主题名称。在这里,主题名称为 topic_test001

--from-beginning:这是一个选项,表示从主题的开始位置开始消费消息,如果不指定该选项,则只会消费接收到该命令之后发出的消息。

        好了,文章到这里就结束了,下周见

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

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

相关文章

【mysql】ACID靠什么保证的呢?

回答: A 原子性:由undo log日志保证,它记录了需要回滚的日志信息,事务回滚时撤销已经执行成功的sql undo log: 我们在进行数据更新操作的时候,不仅会记录redo log,还会记录undo log,如果因为某些原因导致事务回滚,那么这个时候MySQL就要执行回滚(rollback)操作,利用…

Web前端-HTML(表格与表单)

文章目录 1.表格与表单1.1 概述 2.表格 table2.1 表格概述2.2. 创建表格2.3 表格属性2.4. 表头单元格标签th2.5 表格标题caption(了解)2.6 合并单元格(难点)2.7 总结表格 3. 表单标签(重点)3.1 概述3.2 form表单3.3 input 控件(重点)type 属性value属性值…

useEffect 的第二个参数, 传空数组和传依赖数组有什么区别?

在 React 的 useEffect 钩子函数中,第二个参数用于指定依赖项数组。这个参数可以影响 useEffect 的触发时机和频率。 当传递空数组 [] 作为第二个参数时: useEffect 只会在组件初始化渲染完成后执行一次,相当于 componentDidMount。 它不会再…

Android 蓝牙BluetoothAdapter 相关(一)

Android 蓝牙相关 本文主要讲述android 蓝牙的简单使用. 1: 是否支持蓝牙 /*** 是否支持蓝牙** return*/ private boolean isSupportBluetooth() {BluetoothAdapter bluetoothAdapter BluetoothAdapter.getDefaultAdapter();return bluetoothAdapter ! null; }2: 开启蓝牙 …

Java之Clonable接口和深浅拷贝

Clonable接口 我们船舰了一个人的对象,想要克隆一个一模一样的对象,可以用到object类里面的克隆方法 object不是所有类的父类吗?那为什么用person1点不出这个方法呢?可以看一下源码 这是Object类里面的clone方法的声明&#xff0…

HackTheBox-Machines--Analytics

文章目录 1 端口扫描2 测试思路3 漏洞探测4 权限获取5 权限提升 Analytics 测试过程 1 端口扫描 nmap -sC -sV 10.129.205.1422 测试思路 目标服务器只开启了80端口,所以出发点从80端口开始。对于web页面,能做的大致思路有: 1.目录扫描   2…

干货下载丨不分业态、不关注核心需求,怎么做得好项目管理?!

项目管理:装备制造业的破局利刃 对于装备制造行业而言,每一笔订单都是非标定制、小批量制造。这种特性决定了其行业企业普遍存在新品开发周期长、生产效率低、质量不稳定、交货期不稳定、成本预算难控制、非标品报价慢等问题。 如何提升企业的管理水平…

【Java JVM】实例对象的创建

当我们涉及 Java 编程时, 对象的创建是一个基础而关键的概念。在 Java 中, 一切皆为对象, 而对象的创建方式直接影响代码的结构和性能。 本博客将探讨一下 Java 实例对象的创建过程。 1 创建对象的方法有哪些 在 Java 中如果要创建一个对象, 有哪些方式呢? 运用 new 关键字创…

国产or进口?台阶仪为何要选择国产

在微观轮廓测量领域,选择一款合适的台阶仪对于获得精准的测量结果至关重要。随着科技的不断发展,台阶仪市场上涌现了许多国产和进口产品,消费者在选择时可能会面临一些疑虑。 什么是台阶仪 台阶仪是一种超精密接触式微观轮廓测量仪&#xf…

JavaWeb文件上传与下载

一.文件上传 1. 引入两个jar包 jar包可以在maven库进行下载,地址:https://mvnrepository.com,一般点击下载量最多的jar进行下载就可以了。 apache:commons-fileupload.jarcommons-fileupload.jar这个jar包是依赖commons-io.jar的 2. 代码 前端代码&…

桌面概率长按键盘无法连续输入问题

问题描述:概率性长按键盘无法连续输入文本 问题定位: 系统按键流程分析 图一 系统按键流程 按键是由X Server接收的,这一点只要明白了X Window的工作机制就不难理解了。X Server在接收到按键后,会转发到相应程序的窗口中。在窗…

重启docker容器后,ssh无法访问且浏览器无法访问

今天把云服务器中的docker容器重启一遍后,发现里面的项目访问不到了,而且也无法ssh访问。 改了一天,终于还是改好了。 一 .首先是无法ssh访问, 我无法ssh连接的原因是因为我容器的重启之后sshd没有了,然后重新下载了…

助力智能人群检测计数,基于YOLOv5全系列模型【n/s/m/l/x】开发构建通用场景下人群检测计数识别系统

在一些人流量比较大的场合,或者是一些特殊时刻、时段、节假日等特殊时期下,密切关注当前系统所承载的人流量是十分必要的,对于超出系统负荷容量的情况做到及时预警对于管理团队来说是保障人员安全的重要手段,本文的主要目的是想要…

SpringIOC之作用域Scope

博主介绍:✌全网粉丝5W+,全栈开发工程师,从事多年软件开发,在大厂呆过。持有软件中级、六级等证书。可提供微服务项目搭建与毕业项目实战,博主也曾写过优秀论文,查重率极低,在这方面有丰富的经验✌ 博主作品:《Java项目案例》主要基于SpringBoot+MyBatis/MyBatis-plus+…

设计模式之创建型设计模式(一):单例模式 原型模式

单例模式 Singleton 1、什么是单例模式 在软件设计中,单例模式是一种创建型设计模式,其主要目的是确保一个类只有一个实例,并提供一个全局访问点。 这意味着无论何时需要该类的实例,都可以获得相同的实例,而不会创建…

使用VBA快速统计词组词频(多单词组合)(2/2)

实例需求:产品清单如A列所示,现在如下统计多单词组合词组词频。 在上一篇博客中《使用VBA快速统计词组词频(多单词组合)(1/2)》讲解了如何实现双词的词频统计。 本文将讲解如何实现3词的词频统计,掌握实现方法之后&a…

前端Vue必问面试题

1,Vue3.0 为什么要使用 proxy 在 Vue2 中, 0bject.defineProperty 会改变原始数据,而 Proxy 是创建对象的虚拟表示,并提供 set 、get 和 deleteProperty 等处理器,这些处理器可在访问或修改原始对象上的属性时进行拦截,有以下特点∶ 不需用使用 Vue. s e t 或 V u e . s…

硬件编程语言

硬件画板说白了就是电气的连接,相较于PCB连接在2.5D中完成(有些大佬们是直接3D设计)考虑的东西会更多,原理图的抽象使得硬件思路更加简单。 就算是这样, 增加到上千门器件后的大工程是非常难以进行的编辑和检查的&…

Mac如何安装stable diffusion

今天跟大家一起在Mac电脑上安装下stable diffusion,在midjourney等模型收费的情况下如何用自己的电脑算力用上免费的画图大模型呢?来吧一起实操起来 一、安装homebrew 官网地址:Homebrew — The Missing Package Manager for macOS (or Lin…

认识Trino

认识Trino 一、Trino二、结构三、集群四、coordinator五、Worker六、数据源七、连接器八、目录九、架构十、表十一、查询执行模型十二、陈述十三、查询十四、阶段十五、任务十六、分隔十七、Driver十八、Operator十九、Exchange 一、Trino Trino(前身为PrestoSQL&a…