《Dubbo 实现原理与源码解析 —— 精品合集》 《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》 《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》 《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》 《Java 面试题 + Java 学习指南》

摘要: 原创出处 OSC开源社区(ID:oschina2013) 「Travis」欢迎转载,保留摘要,谢谢!


🙂🙂🙂关注微信公众号:【芋道源码】有福利:

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言将得到认真回复。甚至不知道如何读源码也可以请教噢
  4. 新的源码解析文章实时收到通知。每周更新一篇左右
  5. 认真的源码交流微信群。

Apache Kafka 是一个分布式流平台,具有四个核心 API。借助这些 API,Kafka 可以用于以下两大类应用:建立实时流数据管道,可靠地进行数据传输,在系统或应用程序之间获取数据;构建实时流媒体应用程序,以改变系统或应用程序之间的数据或对数据流做出反应。

Apache Kafka 3.0.0 正式发布,这是一个重要的版本更新,其中包括许多新的功能:

  • 已弃用对 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,还有一些其他的配置变化

更多详情可查看:https://blogs.apache.org/kafka

文章目录