Kafka迎来1.0.0版本,告别四位数版本号
极客时间编辑部
讲述:丁婵大小:1.04M时长:02:16
Kafka 从首次发布之日起,已经走过了七个年头,从最开始的大规模消息系统,到现在发展成为功能完善的分布式流式处理平台,用于发布和订阅、存储及实时地处理大规模流数据。来自世界各地的数千家公司在使用 Kafka,包括三分之一的 500 强公司。
Kafka 以稳健的步伐向前迈进,首先加入了复制功能和无边界的键值数据存储,接着推出了用于集成外部存储系统的 Connect API,后又推出了为实时应用和事件驱动应用提供原生流式处理能力的 Streams API,并于今年春季开始支持仅一次处理语义。
如此广泛的应用和完备的功能以及如此悠久的历史,无一不在说明 Kafka 已经成为一款稳定的企业级产品。而现在,Kafka 正式发布了 1.0.0 版本,从发布说明来看,新版本中的新特性主要有以下几点:
0.10.0 版本里开始引入的 Streams API 在 1.0.0 版本里继续演进,改进了 Builder API,新增了用于查看运行时活跃任务的 API 和用于聚合分区的 Cogroup API。
改进了 Connect 的度量指标,新增了大量用于健康监测的度量指标,并提供了集群的 GlobalTopicCount 和 GlobalPartitionCount 度量指标。
支持 Java 9,实现更快的 TLS 和 CRC32C,加快了加密速度,降低了计算开销。
调整了 SASL 认证模块的错误处理逻辑,原先的认证错误信息现在被清晰地记录到日志当中。
更好地支持磁盘容错,更优雅地处理磁盘错误,单个 JBOD 上的磁盘错误不会导致整个集群崩溃。
0.11.0 版本中引入的幂等性,生产者需要将相关参数(max.in.flight.requests.per.connection)设置为 1,这对吞吐量造成了一定的限制。而在 1.0.0 版本里,这个参数最大可以被设置为 5,极大提升了吞吐量范围。
关于新版本的更多变化还可以查看发布说明,也可以通过下载源代码和二进制包来了解。
发布说明:http://t.cn/Rl2szvs
公开
同步至部落
取消
完成
0/2000
荧光笔
直线
曲线
笔记
复制
AI
- 深入了解
- 翻译
- 解释
- 总结
该免费文章来自《极客视点》,如需阅读全部文章,
请先领取课程
请先领取课程
免费领取
© 版权归极客邦科技所有,未经许可不得传播售卖。 页面已增加防盗追踪,如有侵权极客邦将依法追究其法律责任。
登录 后留言
精选留言
由作者筛选后的优质留言将会公开显示,欢迎踊跃留言。
收起评论