【Kafka专栏】windows搭建Kafka环境 & 详细教程(01)

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 【Kafka专栏】windows搭建Kafka环境 & 详细教程(01)


01 引言

1.1 官网地址

官网:https://kafka.apache.org/quickstart

中文官网:https://kafka.apachecn.org/1/#apache-kafka

1.2 概述简介

Apache Kafka 是一个开源分布式事件流平台,已被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序

1.3 kafka与zookeeper

Kafka和Zookeeper之间的关系可以概括为紧密的合作关系。Kafka是一个高性能、可扩展的分布式发布订阅消息系统,主要用于处理大规模的实时数据流。而Zookeeper则是一个分布式协调服务,负责管理和协调分布式系统中的各种资源。

02 部署zookeeper

2.1 下载组件包

官网:https://archive.apache.org/dist/zookeeper/zookeeper-3.6.4/apache-zookeeper-3.6.4-bin.tar.gz
网盘:https://pan.baidu.com/s/1TbgZXmK5_O8W4iZiuFicgw?pwd=yyds

2.2 解压压缩包

(1)解压到任意路径

如:E:\apache-zookeeper-3.6.4-bin

(2)解压后的目录创建数据目录data

如:E:\apache-zookeeper-3.6.4-bin\data

2.3 修改zoo配置

配置文件路径:E:\apache-zookeeper-3.6.4-bin\config

(1)zoo_sample.cfg文件改名为zoo.cfg

(2)修改zoo.cfg文件里面的datadir数据路径

dataDir=/tmp/zookeeper
修改为:dataDir=E:\apache-zookeeper-3.6.4-bin\data

2.4 设置系统变量

1.此电脑–属性–高级系统设置–环境变量–新建zookeeper环境变量

变量名:ZOOKEEPER_HOME

变量值:zk地址,如:E:\apache-zookeeper-3.6.4-bin

2.环境变量Path新建追加%ZOOKEEPER_HOME%\bin

2.5 启动zookeepe服务

(1)服务端启动

tips:使用管理员权限启动cmd命令窗口,执行zkServer启动服务

(2)客户端连接

tips:使用管理员权限再重新启动一个新的cmd命令窗口,执行zkCli

03 部署kafka

3.1 下载组件包

官网:https://downloads.apache.org/kafka/3.5.1/kafka_2.12-3.5.1.tgz
网盘:https://pan.baidu.com/s/1Av4ZwQPUaAntwVxz79Ne9w?pwd=yyds

3.2 解压安装包

(1)解压到任意目录,如:E:\kafka_2.12-3.5.1

(2)解压后创建对应的日志logs目录,如:E:\kafka_2.12-3.5.1\logs

3.3 修改配置

文件路径:E:\kafka_2.12-3.5.1\config\server.properties

log.dirs=/tmp/kafka-logs
改为
log.dirs=E:\kafka_2.12-3.5.1\logs
#listeners=PLAINTEXT://localhost:9092
改为
listeners=PLAINTEXT://localhost:9092

3.4 启动kafka服务端

tips:启动kafka服务端前记得先启动zookeeper服务端

E:
#进入对应的盘
cd kafka_2.12-3.5.1
#启动服务
.\bin\windows\kafka-server-start.bat .\config\server.properties

3.5 创建主题

E:
#进入对应的盘,记得是进入到windows盘,执行bat命令
cd kafka_2.12-3.5.1\bin\windows
#创建主题
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 5 --topic aurora_test
#查询主题
kafka-topics.bat --bootstrap-server localhost:9092 --list

3.6 模拟生产者生成消息

tips:使用管理员权限新建cmd命令窗口,通过生产者生成消息

E:
#进入对应的盘,记得是进入到windows盘,执行bat命令
cd kafka_2.12-3.5.1\bin\windows
#启动生产者
kafka-console-producer.bat --broker-list localhost:9092 --topic aurora_test
#输入任意数据
aaa

3.7 启动消费者消费消息

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic aurora_test --from-beginning

相关文章
|
1月前
|
Java 开发工具 Windows
Windows环境下面启动jar包,输出的日志出现乱码的解决办法
Windows环境下面启动jar包,输出的日志出现乱码的解决办法
|
1月前
|
数据安全/隐私保护 虚拟化 Windows
如何在 VM 虚拟机中安装 Windows Server 2012 操作系统保姆级教程(附链接)
如何在 VM 虚拟机中安装 Windows Server 2012 操作系统保姆级教程(附链接)
74 0
|
1月前
|
数据安全/隐私保护 虚拟化 Windows
如何在 VM 虚拟机中安装 Windows Server 2003 操作系统保姆级教程(附链接)
如何在 VM 虚拟机中安装 Windows Server 2003 操作系统保姆级教程(附链接)
56 0
|
1月前
|
数据安全/隐私保护 虚拟化 Windows
如何在 VM 虚拟机中安装 Windows 7 操作系统保姆级教程(附链接)
如何在 VM 虚拟机中安装 Windows 7 操作系统保姆级教程(附链接)
92 0
如何在 VM 虚拟机中安装 Windows 7 操作系统保姆级教程(附链接)
|
1月前
|
数据安全/隐私保护 虚拟化 Windows
如何在 VM 虚拟机中安装 Windows XP 操作系统保姆级教程(附链接)
如何在 VM 虚拟机中安装 Windows XP 操作系统保姆级教程(附链接)
117 0
|
1月前
|
Unix 编译器 开发者
Qt5.14.2 轻松掌握Qt中的压缩与解压缩:QuaZIP的神秘面纱与实战演练之windows环境编译
Qt5.14.2 轻松掌握Qt中的压缩与解压缩:QuaZIP的神秘面纱与实战演练之windows环境编译
|
4天前
|
安全 Unix Linux
Windows如何远程连接服务器?服务器远程连接图文教程
服务器操作系统可以实现对计算机硬件与软件的直接控制和管理协调,任何计算机的运行离不开操作系统,服务器也一样,服务器操作系统主要分为四大流派:Windows Server、Netware、Unix和Linux。今天驰网飞飞将和你分享Windows server远程连接图文教程,希望可以帮助到你
20 4
Windows如何远程连接服务器?服务器远程连接图文教程
|
1天前
|
5G Python
Windows11搭建Python环境(Anaconda安装与使用)
Windows11搭建Python环境(Anaconda安装与使用)
9 0
|
1天前
|
关系型数据库 MySQL Windows
windows安装MySQL5.7教程
windows安装MySQL5.7教程
8 0
|
1月前
|
数据安全/隐私保护 网络虚拟化 开发者
appuploder全过程使用教程(Windows版本)
appuploder全过程使用教程(Windows版本)