admin 管理员组

文章数量: 887019

Windows系统下搭建Kafka

    • kafka简介
    • 安装JDK
    • 安装zookeeper
    • 安装Kafka
    • kafka演示
      • 创建主题
      • 创建生产者
      • 创建消费者
      • 生产者发送消息，消费者消费消息

kafka简介

Kafka是一个分布式发布——订阅消息传递系统，它最初是由LinkedIn公司开发的，之后成为Apache项目的一部分。Kafka快速、可扩展且耐用。它保留主题中的消息源。生产者将数据写入主题，消费者从主题中读取数据。Kafka是一个分布式，可划分的，冗余备份的持久性的日志服务，它主要用于处理流式数据。具有横向扩展，容错，wicked fast(变态快)等优点，并已在成千上万家公司运行。
详细可查看官网：http://kafka.apache/

安装JDK

  1. JDK下载路径
  2. 按照网上参考步骤，依次配置JAVA_HOME、Classpath和Path，然后打开cmd，运行java -version成功，则JDK配置成功；

安装zookeeper

参考： Windows系统ZooKeeper集群环境搭建

安装Kafka

  1. Kafka下载路径

  2. 下载步骤
    (1) 请求Kafka下载路径

    (2) 注意要下载二进制版本的, 点击下图圈红链接

    (3) 点击点击下图圈红链接进行下载

  3. 下载后解压到任意一个目录，此处我解压的目录是：D:\ruanjian\kafka_2.13-2.5.0

  4. 修改配置文件
    进入目录：D:\ruanjian\kafka_2.13-2.5.0\config，编辑文件"server.properties"

    注意：配置文件中：zookeeper.connect=localhost:2181 是zookeeper的服务地址，请与上面已安装zookeeper服务的地址与端口保持一致。kafka会按照默认配置，在9092端口上运行，并连接zookeeper的默认端口2181。

  5. 启动Kafka服务
    (1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
    (2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
    (3) 输入下面命令
    .\bin\windows\kafka-server-start.bat .\config\server.properties
    (4) 执行成功后日志如下图：

kafka演示

创建主题

(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令

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

(4) 执行成功后日志如下图：

创建生产者

(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令

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

(4) 执行成功后日志如下图：

创建消费者

(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mumu

(4) 执行成功后日志如下图：

生产者发送消息，消费者消费消息


到此kafka安装成功！

本文标签： 系统 Windows Kafka

版权声明：本文标题：Windows系统下搭建Kafka 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.freenas.com.cn/jishu/1725049724h856496.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。