自去年11月从0.x版本跨越到1.x版本,9个月之后,Kafka又迎来了2.0大版本。昨天,Kafka官网正式发布了Kafka 2.0。新版本带来了80多项改进,并修复了120多个bug。以下是新版本的主要特性一览。
支持前缀式ACL,简化了在大规模安全部署中的访问控制管理。
添加OAuth2的Bearer令牌作为Kafka Broker的认证机制,令牌的获取和验证都是可插拔的。
主机名的验证默认启用了SSL,以防止遭到可疑中间人攻击。如果不需要,可疑将其禁用。
现在可以在不重启Kafka Broker的前提下动态更新SSL证书存储。
如果启用了配额,在进行节流时客户端会收到通知。
Kafka消费者客户端添加新的配置选项,用于避免无限阻塞。
不再支持Java 7,并移除了已经弃用的Scala生产者和消费者。
Kafka Streams DSL增加Scala包装API,提供了更好的编译时类型推断和类型安全。
Kafka Streams Processor API支持消息头部,用户可以添加和操作从源主题读取的消息头部,并写入到目标主题。
Kafka Streams的窗口聚合性能得到大幅改进。
领取专属 10元无门槛券
私享最新 技术干货