网站首页 > 博客文章 正文
Apache Kafka 4.0版本于2025年3月18日正式发布,这是Kafka首次完全无需依赖Apache ZooKeeper运行的版本。Kafka 4.0引入了多项重要功能和改进,包括:
- KRaft模式:这是Kafka内置的共识机制,取代了传统的ZooKeeper,简化了部署和管理流程,降低了运营开销,并增强了可扩展性。
- KIP-848(新一代消费者重平衡协议):提高了消费者组的可靠性和响应性,减少了停机时间和延迟。
- KIP-932(Queues for Kafka):使Kafka能够直接支持传统队列语义,扩展了其作为消息平台的适用范围。
- 移除对Java 8和Scala 2.12的支持:Kafka 4.0完全弃用了对Java 8和Scala 2.12的支持,以适应更现代的开发环境。
部署
1.环境准备:
- 确保操作系统符合要求(如Linux系统)。
- 安装Java环境(推荐JDK 17或更高版本),因为Kafka 4.0不再支持Java 8。
- 如果使用Docker,可以选择bitnami的Kafka镜像。
2.下载与安装:
- 从Apache Kafka官网下载最新版本的Kafka安装包(如kafka_2.13-4.0.0.tgz)。
- 解压安装包并进入解压后的目录。
3.配置文件修改:
- 编辑server.properties文件,设置相关参数,如broker.id 、log.dirs、zookeeper.connect等。
- 如果使用KRaft模式,需要配置KRaft相关的参数,如kafka.server.kraft.mode和kafka.server.kraft.zookeeper.connect。
4.启动服务:
- 在终端中运行bin/kafka-server-start.sh config/server.properties启动Kafka服务。
- 如果是KRaft模式,还需要启动KRaft控制器和代理服务。
5.验证部署:
- 使用生产者和消费者测试消息的发送与接收。
- 检查集群状态,确保所有节点正常运行。
6.集群扩展:
- 如果需要部署多节点集群,可以参考KRaft模式下的集群管理方式,通过在线扩展方式增加broker节点。
- 上一篇: Go操作etcd(csgo操作)
- 下一篇: Spark集群:环境搭建之Scala安装指南
猜你喜欢
- 2025-03-30 大数据Hadoop之——Apache Hudi 数据湖实战操作
- 2025-03-30 基于 Flink CDC YAML 的 MySQL 到 Kafka 流式数据集成
- 2025-03-30 Flink SQL 命令行报错(flink sql window)
- 2025-03-30 手把手带你部署ZooKeeper(zookeeper部署方式)
- 2025-03-30 flink1.20集群环境搭建(flinkonyarn集群部署)
- 2025-03-30 群晖DS218+部署kafka(群晖ds218j)
- 2025-03-30 大数据Hadoop之——Kafka Streams原理介绍与简单应用示例
- 2025-03-30 二、Flink部署(flink运行流程)
- 2025-03-30 Scala安装及环境配置(scala安装及环境配置linux)
- 2025-03-30 Kafka 4.0.0 登场:移除 ZooKeeper、重塑实时数据流处理新格局
你 发表评论:
欢迎- 最近发表
-
- 给3D Slicer添加Python第三方插件库
- Python自动化——pytest常用插件详解
- Pycharm下安装MicroPython Tools插件(ESP32开发板)
- IntelliJ IDEA 2025.1.3 发布(idea 2020)
- IDEA+Continue插件+DeepSeek:开发者效率飙升的「三体组合」!
- Cursor:提升Python开发效率的必备IDE及插件安装指南
- 日本旅行时想借厕所、买香烟怎么办?便利商店里能解决大问题!
- 11天!日本史上最长黄金周来了!旅游万金句总结!
- 北川景子&DAIGO缘定1.11 召开记者会宣布结婚
- PIKO‘PPAP’ 洗脑歌登上美国告示牌
- 标签列表
-
- ifneq (61)
- messagesource (56)
- aspose.pdf破解版 (56)
- promise.race (63)
- 2019cad序列号和密钥激活码 (62)
- window.performance (66)
- qt删除文件夹 (72)
- mysqlcaching_sha2_password (64)
- ubuntu升级gcc (58)
- nacos启动失败 (64)
- ssh-add (70)
- jwt漏洞 (58)
- macos14下载 (58)
- yarnnode (62)
- abstractqueuedsynchronizer (64)
- source~/.bashrc没有那个文件或目录 (65)
- springboot整合activiti工作流 (70)
- jmeter插件下载 (61)
- 抓包分析 (60)
- idea创建mavenweb项目 (65)
- vue回到顶部 (57)
- qcombobox样式表 (68)
- vue数组concat (56)
- tomcatundertow (58)
- pastemac (61)
本文暂时没有评论,来添加一个吧(●'◡'●)