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 和 T...