Windows系统下快速启动Kafka

这篇具有很好参考价值的文章主要介绍了Windows系统下快速启动Kafka。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、获取Kafka

下载最新的 Kafka 版本并解压:

Windows系统下快速启动Kafka
打开配置文件:/config/server.properties,进行相应配置修改。

注意:zookeeper.connect=localhost:2181,默认zookeeper为本机端口号2181,如果要以其它ip和端口上的zookeeper服务为环境基础,需要在此进行配置。

二、启动KAFKA环境

注意:您的本地环境必须安装 Java 8+。

2.1 启动zookeeper服务

启动zookeeper服务,如果没有,请前往下载。

下载后,打开zookeeper安装目录,进入bin文件夹,双击zkServer.cmd启动zookeeper服务。

Windows系统下快速启动Kafka

成功启动后,以下页面不要关闭

Windows系统下快速启动Kafka

2.2 启动Kafka服务

进入到Kafka安装目录:

Windows系统下快速启动Kafka

勾选bin文件夹,按下Shift+右键,选择“选择在此处打开 Powersheel 窗口”

Windows系统下快速启动Kafka

输入命令: start cmd,Enter回车

Windows系统下快速启动Kafka

弹出命令窗口:

Windows系统下快速启动Kafka

提示:除了上面这种启动命令窗口方式,还有一种更为快捷的方式:在对应的文件夹目录框内输入 cmd 后按回车键,也会直接弹出命令窗口。

通过运行D:\Develop\kafka_2.13-3.4.0\bin\windows\文件夹下的 kafka-server-start.bat 脚本文件并指定配置文件来启动Kafka服务

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

Windows系统下快速启动Kafka

启动成功后,页面也不要关闭

Windows系统下快速启动Kafka

2.3 验证 Kafka 服务是否正常工作

重新打开一个命令窗口,并使用以下命令验证 Kafka 是否正常工作

.\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

Windows系统下快速启动Kafka

如果能够输出 Kafka 中所有的主题列表,则表示 Kafka 正常工作。

三、操作Kafka

3.1 创建 Kafka 主题(Topic)

例如,创建一个主题(Topic)为 quick_start_topic 的主题:

.\windows\kafka-topics.bat --create --topic quick_start_topic --bootstrap-server localhost:9092

Windows系统下快速启动Kafka

创建完之后,可以使用以下命令查看刚创建的主题的分区计数等详细信息:

.\windows\kafka-topics.bat --describe --topic quick_start_topic --bootstrap-server localhost:9092

Windows系统下快速启动Kafka

3.2 将一些事件写入主题(Topic)

Kafka 客户端通过网络与 Kafka 代理通信以写入(或读取)事件。一旦收到,代理将以持久和容错的方式存储事件,只要您需要——甚至永远。

运行控制台生产者客户端以将一些事件写入您的主题。默认情况下,您输入的每一行都会导致一个单独的事件被写入主题。

.\windows\kafka-console-producer.bat --topic quick_start_topic --bootstrap-server localhost:9092

Windows系统下快速启动Kafka
Ctrl-C 可以随时停止生产者客户端。

3.3 读取事件

打开另一个终端会话并运行控制台消费者客户端以读取刚刚创建的事件:

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

Windows系统下快速启动Kafka
然而,在读取quick_start_topic主题内的事件时,由于之前生产者写入了一条中文事件。在消费者客户端读取时,出现了中文乱码。

事件持久存储在 Kafka 中,所以它们可以被任意多次读取,并且可以被任意多的消费者读取。文章来源地址https://www.toymoban.com/news/detail-419150.html

到了这里,关于Windows系统下快速启动Kafka的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 如何给Windows电脑重装系统+新系统设置(从检查到实施,看这一篇就够了!)包含BitLocker的备份,镜像的下载,启动盘的制作,安装的流程,驱动的下载,新电脑的设置等各个方面。

    如何给一个Windows电脑(任意版本)重装win11(此方法Windows10适用)系统? 在此之前都需要注意(或检查)什么方面? 会出现什么问题以及其解决方法? 这篇文章会给予读者一个完整的解答。 大家好,我是爱好计算机的初中生一名 由于电脑磁盘内存有限以及最近考试学习的

    2024年02月03日
    浏览(61)
  • Kafka(Windows)安装配置启动(常见错误扫雷)教程

    访问Kafka: https://kafka.apache.org/downloads 选择相应的版本 下载到本地后,将文件解压到 D:kafka_2.11-2.4.0,该文件夹包括了所有相关的运行文件及配置文件,其子文件夹binwindows 下放的是在Windows系统启动zookeeper和kafka的可执行文件,子文件夹config下放的是zookeeper和kafka的配置文件。

    2024年02月09日
    浏览(34)
  • python --windows获取启动文件夹路径/获取当前用户名/添加自启动文件

    一、Python自带的getpass模块可以用于获取用户输入的密码,但是它同样可以用来获取计算机用户名。 二、使用os模块获取用户名 Python的os模块在获取系统信息方面提供了很多方法,其中也包括获取计算机用户名的方法。 三、使用psutil模块获取用户名 psutil是Python中一个跨平台的

    2024年02月14日
    浏览(63)
  • 【Burp Suite】Burp Suite下载及快速启动

    ● 官方文档地址: https://portswigger.net/burp/documentation/contents ● 官方下载地址: https://portswigger.net/burp/releases ● 选择要下载的版本及安装包,JAR包也要下载,以Windows为例。 ● 下载后直接对应用程序安装即可,无需任何配置。 ● 安装后,将JAR包与Burp Loader Keygen.jar放到安装目

    2024年02月09日
    浏览(46)
  • windows/linux 安装zookeeper + Kafka (含自启动)运行教学

    首先我们来花两分钟了解一下: Zookeeper 和 Kafka 都是 Apache 软件基金会中的开源软件。 Zookeeper 是一个分布式协调服务,它提供了一个基于树形结构的命名空间来协调分布式系统的各个部分。Zookeeper 能够跟踪各个分布式系统组件的状态,并在这些组件之间协调消息传递,从而

    2024年02月08日
    浏览(35)
  • windows快速一键启动多个软件脚本bat

    每次打开电脑都想启动多个软件,而开启开机自启又会拖慢开机速度,万一某天不需要开启这么多软件又会影响开机速度,还需要一个一个关闭,就很麻烦 使用bat文件即可自定义开启多个软件  首先新建一个文本文档, 按照以下格式编写: start + 空格 + /d + \\\"软件的所在绝对路径\\\" + 空

    2024年02月12日
    浏览(45)
  • Windows Update启动不了如何解决?教你快速修复

    前段时间看到某视频博主关闭系统更新的方法,他方法是把c盘-SoftwareDistribution-download文件夹的所有用户权限都设为拒绝,这样的方法导致系统永远也不会更新了,也会导致自己进不去Windows更新的高级选项,也难以删掉download里的文件。 由于我在使用淘晶驰的串口屏的上位机

    2024年02月13日
    浏览(43)
  • windows 下载安装Redis,并配置开机自启动

    1. 下载 地址:https://github.com/tporadowski/redis/releases Redis 支持 32 位 和 64 位 。这个需要根据你系统平台的实际情况选择,这里我们下载 Redis-x64-xxx.zip压缩包,之后解压 打开解压到的文件夹,内容如下: 2. cmd窗口运行redis 3. 验证redis是否启动成功 这时候另启一个 cmd 窗口,原来的

    2024年02月16日
    浏览(38)
  • Windows下快速安装Nginx并配置开机自动启动Nginx

    目录 一、windows系统下Nginx安装启动流程: 二、设置Nginx开机自动启动 1、自启动工具下载 2、自启动工具安装 3、把nginx加入到windows服务中 nginx已经是我们日常开发中在常用不过的工具了,简单快捷的安装和配置,大大减少了我们部署调试浪费的时间,本文给各位同学介绍一下

    2024年02月10日
    浏览(54)
  • 使用Gitee极速下载Nacos项目制作windows启动

    nacos官网下载非常慢且非常易于中断,因此记录通过国内链接极速下载nacos的开源项目而后使用maven制作成windows版的启动项 使用国内链接下载nacos项目 :https://gitee.com/mirrors/Nacos 进入下载好的nacos主目录下执行maven打包命令,在此之前需要配置好Maven   打包成功的结果图 打包好

    2024年02月03日
    浏览(42)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包