Kafka1.0.0版本

Kafka 1.0.0发布的主要内容如下。

0.10.0版本里开始引入的Streams API在1.0.0版本里继续演进,改进了builder API(KIP-120),新增了用于查看运行时活跃任务的API(KIP-130)和用于聚合分区的cogroup
API(KIP-150)。增强的print()和writeAsText()方法让调试变得更容易(KIP-160)。其他更多信息可以参考Streams文档。
改进了Connect的度量指标(KIP-196),新增了大量用于健康监测的度量指标(KIP-188),并提供了集群的GloabalTopicCount和GlobalPartitionCount度量指标(KIP-168)。
支持Java 9,实现更快的TLS和CRC32C,加快了加密速度,降低了计算开销。
调整了SASL认证模块的错误处理逻辑(KIP-152),原先的认证错误信息现在被清晰地记录到日志当中。
更好地支持磁盘容错(KIP-112),更优雅地处理磁盘错误,单个JBOD上的磁盘错误不会导致整个集群崩溃。
0.11.0版本中引入的幂等性生产者需要将max.in.flight.requests.per.connection参数设置为1,这对吞吐量造成了一定的限制。而在1.0.0版本里,这个参数最大可以被设置为5(KAFKA-5949),极大提升了吞吐量范围。

关于新版本更多的变化可以查看发布说明,也可以下载源代码和二进制包(Scala 2.11Scala 2.12)。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容