消息中间件ApacheKafka在windows简单安装

一.背景

      之前公司需要API网关管理软件ApacheShenYu,我相信把调用的记录都存到一个数据库。他支持日志推送到kafka,所以,我准备尝试一下通过kafka接收调用的日志信息。第一步,当然是安装kafka了。

二.ApacheKafka的下载

打开下载界面Apache Kafka

我点击的是这个。

三.ApacheKafka在windows下面的安装

      kafka依赖于zookeeper,都在下载的包里面了。安装解压后需要放到盘符的根目录下面,我之前没有放根目录有点问题,后续空了再查找详细原因。

     1.解压到D:\kafka_2.13-3.7.1

     2.创建目录 

      D:\kafka_2.13-3.7.1\data\zookeeper

      D:\kafka_2.13-3.7.1\data\kafka

     3.修改配置文件

     1)D:\kafka_2.13-3.7.1\config\zookeeper.properties

    修改dataDir即可

    dataDir=D:/kafka_2.13-3.7.1/data/zookeeper

    2)D:\kafka_2.13-3.7.1\config\server.properties

    修改 log.dirs即可

    log.dirs=D:/kafka_2.13-3.7.1/data/kafka

四.ApacheKafka启动

   1.先启动zookeeper

   打开cmd,运行启动命令及参数   

cd /d D:\kafka_2.13-3.7.1\bin\windows
zookeeper-server-start.bat ../../config/zookeeper.properties

     仔细看,如果有INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory),应该就启动正常了。

   2.启动kafka

     打开cmd,运行启动命令及参数   

cd /d D:\kafka_2.13-3.7.1\bin\windows
kafka-server-start.bat ../../config/server.properties

     如果有下面两句,一般就没有问题了。

    Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
    Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient)

五.测试ApacheKafka是否正常

    1.创建一个topic    

  新打开一个cmd窗口,输入如下两个命令:

cd /d D:\kafka_2.13-3.7.1\bin\windows
kafka-console-producer.bat  --bootstrap-server localhost:9092 --topic test-topic

    这样,我们就创建了一个叫test-topic的主题了。

   2.接收消息

      再新打开一个cmd窗口,输入如下两个命令:  

cd /d D:\kafka_2.13-3.7.1\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic

   这样,我们开始监听test-topic主题了。

    3.发送与接收查看

     在刚刚创建窗口输入hello,你就可以在监听窗口收到hello了。如下图:

   

六.中文乱码的处理

    唉!手贱,本想写文章就简单说下思路就行了。但是输入了个中文,看到了乱码,我就受不了,解决吧!

   暂时留在这里,后续修改。。。

七.退出

    开发状态,也不用管优雅了。直接关闭相关的cmd窗口,就退出了topic的监听,关闭了kafka、zookeeper了。后面生产部署才去了解优雅的启动与关闭吧!

    

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Docker-自定义镜像发布到DockerHub仓库、阿里云仓库

文章目录 推送镜像DockerHub仓库推送镜像阿里云仓库 更多相关内容可查看 推送镜像DockerHub仓库 在服务器中 使用 docker 登录命令 docker login -u 账户 #enter 后输入密码推送镜像到DockerHub docker push 镜像名:tag但个人不建议推送到DockHub上,毕竟不是咱自…

【Python机器学习】处理文本数据——停用词

删除没有信息量的单词有一种方法,就是舍弃那些出现次数太多以至于没有信息量的单词。 有两种主要方法: 1、使用特定语言的停用词(stopword)列表; 2、舍弃那些出现过于频繁的单词。 scikit-learn的feature_extracti…

gradle构建工具

setting.gradle // settings.gradle rootProject.name my-project // 指定根项目名称include subproject1, subproject2 // 指定子项目名称,可选jar包名称 方式一 jar {archiveBaseName my-application // 设置 JAR 文件的基本名称archiveVersion 1.0 // 设置…

阿里云RDS云数据库库表恢复操作

最近数据库中数据被人误删了,记录一下恢复操作方便以后发生时进行恢复. 1.打开控制台,进入云数据库实例. 2.进入实例后 ,点击右侧的备份恢复,然后看一下备份时间点,中间这边都是阿里云自动备份的备份集,基本都是7天一备…

与Flat Ads相约ChinaJoy 2024,共探全球化增长

在当今全球数字化浪潮的推动下,游戏产业作为文化与技术融合的先锋,正以前所未有的速度跨越国界,开启全球化发展的新篇章。随着第二十一届ChinaJoy的临近,全球的目光再次聚焦于上海新国际博览中心,这里即将成为数字娱乐与科技创新碰撞与交融的璀璨舞台。 而在这场盛会上,Flat A…

Python酷库之旅-第三方库Pandas(004)

目录 一、用法精讲 5、pandas.DataFrame.to_csv函数 5-1、语法 5-2、参数 5-3、功能 5-4、返回值 5-5、说明 5-6、用法 5-6-1、代码示例 5-6-2、结果输出 6、pandas.read_fwf函数 6-1、语法 6-2、参数 6-3、功能 6-4、返回值 6-5、说明 6-6、用法 6-6-1、代码…

某积分商城任意金额支付漏洞分析利用及思考

扫码领取网安教程 大部分开发人员在开发时都会有一种思维惯性,传参处处有校验处处都可信,但这个等式并非恒成立 前言 这个漏洞是在工作中例行渗透测试的时候发现的,虽然前端做了防篡改措施,但这是很经典的没有后端校验导致的任意…

【CSAPP】-attacklab实验

目录 实验目的与要求 实验原理与内容 实验设备与软件环境 实验过程与结果(可贴图) 实验总结 实验目的与要求 1. 强化机器级表示、汇编语言、调试器和逆向工程等方面基础知识,并结合栈帧工作原理实现简单的栈溢出攻击,掌握其基…

sql注入问题批量处理

问题:SQL注入修改,历史代码全是${};无法修改的比如表名,列名,动态排序之类的不改,其他的都要修改完成 背景:新公司第一个任务就是SQL注入的修改,历史sql全部都是${},一个个调整不太合适只能批量…

ubuntu 安装说明

最近准备学习Linux,所以下载了最新的ubuntu server版本24.04,将安装步骤记录下来供参考。 1.安装 挂载光驱和iso文件,启动虚拟机。启动后,你会看到 GRUB 菜单上有两个选项: Try or Install Ubuntu Server 和 Test mem…

六西格玛培训公司:实战教学,让品质管理不再纸上谈兵!

在追求卓越与品质管理的征途上,六西格玛培训公司张驰咨询凭借其深厚的行业底蕴与前瞻性的战略眼光,成为了引领行业变革的重要力量。公司不仅深谙六西格玛精髓,更将这一先进的质量管理方法论转化为推动企业转型升级的强大动力,以“…

碳课堂|搞清楚碳足迹,只看这篇文章就够了

碳足迹管理是碳达峰碳中和的重要政策工具,2023年12月,国家发展改革委、工信部、国家市场监管总局、住房城乡建设部、交通运输部等部门联合印发《关于加快建立产品碳足迹管理体系的意见》,对产品碳足迹管理各项重点任务作出系统部署。 推动碳…

泛型 + 反射 + 注解 + 动态代理 + 设计模式 + Factory(BeanFactory,FactoryBean)

1.泛型 编译器可以对泛型参数进行检测&#xff0c;并且通过泛型参数可以指定传入的对象类型。比如 ArrayList<Person> persons new ArrayList<Person>() 这行代码就指明了该 ArrayList 对象只能传入 Person 对象&#xff0c;如果传入其他类型的对象就会报错。 原…

爬虫进阶:Selenium与Ajax的无缝集成

爬虫与Ajax的挑战 Ajax&#xff08;Asynchronous JavaScript and XML&#xff09;允许网页在不重新加载整个页面的情况下与服务器交换数据并更新部分内容。这为用户带来了更好的体验&#xff0c;但同时也使得爬虫在抓取数据时面临以下挑战&#xff1a; 动态内容加载&#xff…

【基础算法】UE中实现轮播

本期作者&#xff1a;尼克 易知微3D引擎技术负责人 当前N 总数M 从0到M-1 从1到M 感谢阅读&#xff0c;以上内容均由易知微3D引擎团队原创设计&#xff0c;以及易知微版权所有&#xff0c;转载请注明出处&#xff0c;违者必究&#xff0c;谢谢您的合作。申请转载授权后台回复【…

C++基石:掌握高效编程的艺术

C 关于命名空间&#xff1a;namespace 上述文档详细介绍了C标准库&#xff08;Standard C Library&#xff09;的一些关键约定&#xff0c;这些约定不仅帮助开发者理解如何正确使用库中的功能&#xff0c;也明确了实现者在设计库时的灵活性和限制。下面是对文档中提到的几个要点…

基于Java中的SSM框架实现物流管理系统项目【项目源码+论文说明】

基于Java中的SSM框架实现物流管理系统演示 摘要 企业的发展离不开物流的运输&#xff0c;在一个大型的企业中&#xff0c;商品的生产和建设&#xff0c;推广只是前期的一些工作&#xff0c;在后期的商品销售和物流方面的建立&#xff0c;才能让一个企业得到大力的发展。 企业…

Mysql中间件和高可用

文章目录 一、MySQL中间件代理服务器MycatMycat应用场景Mycat部署 实现读写分离 二、MySQL高可用高可用解决方案MHA高可用实现MHA 一、MySQL中间件代理服务器 数据库主要分为两大类&#xff1a;关系型数据库与 NoSQL 数据库&#xff08;非关系型数据库&#xff09;。 数据库主…

MinIO:开源对象存储解决方案的领先者

MinIO:开源对象存储解决方案的领先者 MinIO 是一款开源的对象存储系统&#xff0c;致力于提供高性能、可伸缩、安全的数据存储解决方案。 官方解释&#xff1a;MinIO 是一个基于Apache License v2。0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口&#xff0c;非常适…

vue 模糊查询加个禁止属性

vue 模糊查询加个禁止属性 父组件通过属性传&#xff0c;是否禁止输入-------默认可以输入