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