本文基于Kafka2.7
Kafka是中间件,对于消费完成的数据,需要有清理机制来保障集群的正常运行。
Kafka数据文件运行时提供checkpoint机制,保证数据的一致性
基于kafka2.8.0版本,描述kafka文件系统结构
本文基于kafka-2.8.0和kafka-3.5.0,探讨kafka集群id的生成逻辑的演变
描述Kafka命令行操作,以及当前支持的使用场景,这对评估客户需求以及实现方案的可行性特别重要。
当前kafka最新版本是3.6.0。本文主要讲述三个配置:listeners、advertised.listeners、listener.security.protocol.map
kafka数据迁移方案
Kafka3.6.2版本内容和发布时间
本文基于kafka2.7源码,介绍Kafka服务端相关的配置,属性定义在类kafka.server.KafkaConfig.scala中,通过功能分类,可分为以下20个大类,共215个配置属性,下面分别进行介绍。