总阅读量:次

⭐⭐⭐ Spring Boot 项目实战 ⭐⭐⭐ Spring Cloud 项目实战
《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

文章目录