环境准备:

1、下载最新版的kafka(注:最新版kafka自带zookeeper,无需单独安装),点此下载,下载时请勿下载带src的包(示例包:kafka_2.12-3.1.0.tgz)

2、kafka需要java环境,需自行安装jdk

安装流程:

1、解压kafka_2.12-3.1.0.tgz包

2、打开cmd,启动zookeeper(操作如下):

①、切换到kafka根目录(命令:cd D:\tools\kafka_2.12-3.1.0)

②、启动zookeeper(命令:bin\windows\zookeeper-server-start.bat config\zookeeper.properties)

3、新开一个cmd,启动kafka(操作如下):

①、切换到kafka根目录(命令:cd D:\tools\kafka_2.12-3.1.0)

②、启动kafka(命令:bin\windows\kafka-server-start.bat config\server.properties)

4、到此,kafka启动成功,可进行测试(请勿关闭第2和3点中的cmd),如:

①、创建主题(命令:bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test)

②、查看创建的主题(命令:bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092)

注:其他命令可以自行查阅哦

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐