【Kafka】Windows+KRaft部署指南
- 摘要
- 本地环境说明
- 官网
- 快速开始
- 修改config/kraft/server.properties
- 初始化数据存储目录
- 启动
- 测试
- 创建topic
- 创建生产者
- 创建消费者
- FAQ
- 输入行太长。命令语法不正确。
- 问题描述
- 解决方案
- 参考资料
摘要
Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。其核心组件包含Producer、Broker、Consumer，以及依赖的Zookeeper集群。其中Zookeeper集群是Kafka用来负责集群元数据的管理、控制器的选举等。
用过kafka的开发者应该知道，每次启动kafka服务时，都是需要先把Zookeeper启动，然后启动kafka，步骤相当繁琐。
Kafka在使用的过程当中，会出现一些问题。由于重度依赖Zookeeper集群，当Zookeeper集群性能发生抖动时，Kafka的性能也会收到很大的影响。因此，在Kafka发展的过程当中，为了解决这个问题，提供KRaft模式3.0+版本，来取消Kafka对Zookeeper的依赖。
Kafka是依赖于JDK的，需要先把java环境配置一下。
本地环境说明
| 依赖 | 版本 |
|---|---|
| JDK | 21 |
| Windows | 11 |
| Kafka | 3.9.0 |
官网
- 下载页面:
https://kafka.apache.org/downloads
3.9.0下载地址:https://downloads.apache.org/kafka/3.9.0/kafka_2.13-3.9
