Kafka 3.0重磅发布,弃用 Java 8 的支持!
Java技术前线
共 7758字,需浏览 16分钟
·
2021-10-24 08:25
建立实时流数据管道,可靠地进行数据传输,在系统或应用程序之间获取数据。
构建实时流媒体应用程序,以改变系统或应用程序之间的数据或对数据流做出反应。
已弃用对 Java 8 和 Scala 2.12 的支持,对它们的支持将在 4.0 版本中彻底移除,以让开发者有时间进行调整。
Kafka Raft 支持元数据主题的快照,以及 self-managed quorum 方面的其他改进。
废弃了消息格式 v0 和 v1。
默认情况下为 Kafka Producer 启用更强的交付保证。
优化了 OffsetFetch 和 FindCoordinator 请求。
更灵活的 MirrorMaker 2 配置和 MirrorMaker 1 的弃用。
能够在 Kafka Connect 的一次调用中重新启动连接器的任务。
连接器日志上下文和连接器客户端覆盖现在是默认启用的。
增强了 Kafka Streams 中时间戳同步的语义。
修改了 Stream 的 TaskId 的公共 API。
在 Kafka Streams 中,默认的 serde 变成了 null,还有一些其他的配置变化。
常规变化
①KIP-750(第一部分):弃用 Kafka 中对 Java 8 的支持
②KIP-751(第一部分):弃用 Kafka 中对 Scala 2.12 的支持
Kafka 代理、生产者、消费者和管理客户端
①KIP-630:Kafka Raft 快照
②KIP-746:修改 KRaft 元数据记录
③KIP-730:KRaft 模式下的生产者 ID 生成
④KIP-679:Producer 将默认启用最强的交付保证
⑤KIP-735:增加默认消费者会话超时
⑥KIP-709:扩展 OffsetFetch 请求以接受多个组 ID
⑦KIP-699:更新 FindCoordinator 以一次解析多个 Coordinator
⑧KIP-724:删除对消息格式 v0 和 v1 的支持
⑨KIP-707:KafkaFuture 的未来
⑩KIP-466:添加对 List 序列化和反序列化的支持
⑪KIP-734:改进 AdminClient.listOffsets 以返回时间戳和具有最大时间戳的记录的偏移量
Kafka Connect
①KIP-745:连接 API 以重新启动连接器和任务
②KIP-738:删除 Connect 的内部转换器属性
③KIP-722:默认启用连接器客户端覆盖
④KIP-721:在连接 Log4j 配置中启用连接器日志上下文
Kafka Streams
①KIP-695:进一步改进 Kafka Streams 时间戳同步
②KIP-715:在流中公开提交的偏移量
③KIP-740:清理公共 API TaskId
④KIP-744:迁移 TaskMetadata,并 ThreadMetadata 与内部实现的接口
⑤KIP-666:添加 Instant 基于方法到 ReadOnlySessionStore
⑥KIP-622:添加 currentSystemTimeMs 和 currentStreamTimeMs 到 ProcessorContext
⑦KIP-743:删除 0.10.0-2.4Streams 内置指标版本配置的配置值
⑧KIP-741:将默认 SerDe 更改为 null
⑨KIP-733:更改 Kafka Streams 默认复制因子配置
⑩KIP-732:弃用 eos-alpha 并用 eos-v2 替换 eos-beta
⑪KIP-725:优化 WindowedSerializer 和 WindowedDeserializer 的配置
⑫KIP-633:弃用 Streams 中宽限期的 24 小时默认值
⑬KIP-623:internal-topics 为流应用程序重置工具添加“ ”选项
MirrorMaker
①KIP-720:弃用 MirrorMaker v1
②KIP-716:允许使用 MirrorMaker2 配置偏移同步主题的位置
最近面试BAT,整理一份面试资料《Java面试BATJ通关手册》,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。
获取方式:点“在看”,关注公众号并回复 Java 领取,更多内容陆续奉上。
文章有帮助的话,在看,转发吧。
谢谢支持哟 (*^
评论