网站首页 > 博客文章 正文
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、重塑实时数据流处理新格局
你 发表评论:
欢迎- 374℃手把手教程「JavaWeb」优雅的SpringMvc+Mybatis整合之路
- 369℃用AI Agent治理微服务的复杂性问题|QCon
- 360℃初次使用IntelliJ IDEA新建Maven项目
- 353℃Maven技术方案最全手册(mavena)
- 351℃安利Touch Bar 专属应用,让闲置的Touch Bar活跃起来!
- 349℃InfoQ 2024 年趋势报告:架构篇(infoq+2024+年趋势报告:架构篇分析)
- 348℃IntelliJ IDEA 2018版本和2022版本创建 Maven 项目对比
- 344℃从头搭建 IntelliJ IDEA 环境(intellij idea建包)
- 最近发表
- 标签列表
-
- powershellfor (55)
- 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)
本文暂时没有评论,来添加一个吧(●'◡'●)