Apache Kafka 2.8.0 发布

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

近日 Apache Kafka 2.8.0 正式发布，本次更新的显著变化如下：

• 增加描述群组 API；
• 支持 SASL_SSL 监听器上的相互 TLS 认证；
• JSON 请求/响应调试日志。
• 限制 broker 连接创建率；
• 主题标识符；
• 在 Connect REST API 中公开任务配置；
• 早期访问用一个自我管理的 Quorum 取代 ZooKeeper；
• 更新 Streams FSM，以表明错误状态的含义；
• 扩展 StreamJoined 以允许更多的 store 配置；
• 更加方便的 TopologyTestDriver construtors；
• 引入Kafka-Stream特有的未捕获异常 handler；
• 启动和关闭 Streams 线程的 API；
• 改进 TimeWindowedDeserializer 和 TimeWindowedSerde，以处理窗口尺寸；
• 改进 Kafka stream 中的超时和重试；

更多详情可查看：https://www.apache.org/dist/kafka/2.8.0/RELEASE_NOTES.html