Windows下安装kafka

ops/2025/3/13 4:14:47/

在 Windows 系统下安装 Kafka 可以按照以下步骤进行:

1. 安装 Java 环境

Kafka 是基于 Java 开发的,因此需要先安装 Java 环境。

  • 下载 Java:访问 Oracle Java 下载页面 或 OpenJDK 下载页面,选择适合你系统的 Java 版本(建议 Java 8 及以上)进行下载。
  • 安装 Java:运行下载的安装程序,按照提示完成安装。
  • 配置环境变量
    • 右键点击“此电脑”,选择“属性”。
    • 点击“高级系统设置”,在弹出的窗口中点击“环境变量”。
    • 在“系统变量”中找到“Path”变量,点击“编辑”,将 Java 的 bin 目录路径(例如 C:\Program Files\Java\jdk-11\bin)添加到“Path”变量中。
    • 新建“JAVA_HOME”系统变量,变量值为 Java 的安装目录(例如 C:\Program Files\Java\jdk-11)。

2. 下载 Kafka

  • 访问 Apache Kafka 官方下载页面,选择合适的 Kafka 版本(建议选择最新的稳定版本),下载 Binary downloads 下的压缩包。
  • 将下载的压缩包解压到你想要安装 Kafka 的目录,例如 C:\kafka

3. 配置 Zookeeper

Kafka 依赖 Zookeeper 来管理集群元数据和协调节点。Kafka 自带了 Zookeeper,你可以直接使用。

  • 打开 C:\kafka\config 目录,找到 zookeeper.properties 文件。
  • 通常情况下,你可以使用默认配置,不需要进行修改。

4. 配置 Kafka

  • 打开 C:\kafka\config 目录,找到 server.properties 文件。
  • 可以根据需要修改以下配置:
    • log.dirs:指定 Kafka 消息日志的存储目录,例如 log.dirs=C:/kafka/kafka-logs
    • listeners:指定 Kafka 监听的地址和端口,默认是 PLAINTEXT://:9092

5. 启动 Zookeeper

  • 打开命令提示符(CMD),切换到 Kafka 的安装目录:
cd C:\kafka
  • 启动 Zookeeper 服务:
bin\windows\zookeeper-server-start.bat config\zookeeper.properties

如果一切正常,你会看到 Zookeeper 成功启动的日志信息。

6. 启动 Kafka

  • 打开另一个命令提示符(CMD),切换到 Kafka 的安装目录:
cd C:\kafka
  • 启动 Kafka 服务:
bin\windows\kafka-server-start.bat config\server.properties

如果启动成功,你会看到 Kafka 服务的启动日志。

7. 验证安装

  • 创建主题:打开一个新的命令提示符,切换到 Kafka 安装目录,执行以下命令创建一个名为 test 的主题:
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
  • 发送消息:执行以下命令启动一个生产者,向 test 主题发送消息:
bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test

在命令行中输入一些消息,按回车键发送。

  • 接收消息:打开另一个命令提示符,切换到 Kafka 安装目录,执行以下命令启动一个消费者,接收 test 主题的消息:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

如果你能在消费者的命令行中看到之前生产者发送的消息,说明 Kafka 安装和配置成功。

8. 关闭服务

当你不再需要使用 Kafka 时,可以按以下步骤关闭服务:

  • 先关闭 Kafka 服务:在 Kafka 服务的命令提示符窗口中,按 Ctrl + C 停止服务。
  • 再关闭 Zookeeper 服务:在 Zookeeper 服务的命令提示符窗口中,按 Ctrl + C 停止服务。

通过以上步骤,你就可以在 Windows 系统下成功安装和使用 Kafka。


http://www.ppmy.cn/ops/165320.html

相关文章

ubuntu 解决 DNS 代理设置错误,导致不能上网的 DoH、DoT问题

老旧的 udp dns明文查询,早就被 doh ,dot取代了。优选 doh,更自在。 但目前的现状是 3种 DNS 传输协议 udp / doh / dot 同时存在。 未来,如何选择? 测试: udp dns:简单方便内网:do…

OpenGL ES ->帧缓冲对象(Frame Buffer Object)离屏渲染获取纹理贴图

XML文件 <?xml version"1.0" encoding"utf-8"?> <RelativeLayout xmlns:android"http://schemas.android.com/apk/res/android"android:layout_width"match_parent"android:layout_height"match_parent"><…

PostgreSQL - Windows PostgreSQL 下载与安装

Windows PostgreSQL 下载与安装 1、PostgreSQL 下载 下载地址&#xff1a;https://www.enterprisedb.com/downloads/postgres-postgresql-downloads 2、PostgreSQL 安装 启动安装程序 -> 点击 【Next】 指定安装路径 -> 点击 【Next】 默认勾选 -> 点击 【Next】 指…

回顾一下Qt的多线程技术以及实际开发常用场景

在 Qt 中&#xff0c;多线程编程是一项重要的技术&#xff0c;它允许程序同时执行多个任务&#xff0c;从而提高程序的性能和响应能力。下面将详细介绍 Qt 中的多线程编程&#xff0c;包括相关类、使用方法以及实际运用场景例子。 1. Qt 中多线程编程的相关类 QThread QThre…

如何找回已删除的 Git 远程和本地分支

在日常开发中&#xff0c;我们有时可能会误删 Git 分支&#xff0c;无论是本地分支还是远程分支。如果发现自己需要找回已删除的分支&#xff0c;不要惊慌&#xff0c;Git 提供了一些方法来帮助我们恢复它。本文将介绍几种常见的恢复方法。 方法 1&#xff1a;使用 Git reflog …

win10电脑鼠标速度突然变的很慢?

电脑鼠标突然变很慢&#xff0c;杀毒检测后没问题&#xff0c;鼠标设置也没变&#xff0c;最后发现可能是误触鼠标的“DPI”调节键。 DPI调节键在鼠标滚轮下方&#xff0c;再次点击即可恢复正常鼠标速度。 如果有和-的按键&#xff0c;速度变快&#xff0c;-速度变慢。 图源&…

P8700 [蓝桥杯 2019 国 B] 解谜游戏--string与cstring、memset()介绍

P8700 [蓝桥杯 2019 国 B] 解谜游戏--string与cstring 题目 解析代码 题目 解析 借大佬图用用&#xff0c;内中外圈的数量比是1&#xff1a;2&#xff1a;3&#xff0c;所以无论怎么旋转在内圈的一个位置都对应着中圈的两个位置以及外圈的三个位置&#xff08;这个是固定的&…

swift -(5) 汇编分析结构体、类的内存布局

一、结构体 在 Swift 标准库中&#xff0c;绝大多数的公开类型都是结构体&#xff0c;而枚举和类只占很小一部分 比如Bool、 Int、 Double、 String、 Array、 Dictionary等常见类型都是结构体 ① struct Date { ② var year: Int ③ var month: Int ④ …