Apache Kafka 0.11.0.2 已发布。这是一个错误修复版本,包含 16 个来自 JIRA 的修复和改进,其中包括一些严重的错误。
具体更新内容如下:
Bug
Flaky ResetIntegrationTest
Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()
Deadlock due to locking of DelayedProduce and group
Streams State Restoration never completes when logging is disabled
Replication Fetcher thread for a partition with no data fails to start
KafkaFuture timeout fails to fire if a narrow race condition is hit
Integer overflow in log cleaner cleanable ratio computation
Kafka Request Handler deadlocks and brings down the cluster.
Scanning plugin.path needs to support relative symlinks
Major performance issue due to excessive logging during leader election
Silent Data Loss in Kafka011 Transactional Producer
Transaction markers are sometimes discarded if txns complete concurrently
High memory usage on controller during partition reassignment
RecordQueue.clear() does not clear MinTimestampTracker's maintained list
GlobalKTable never finishes restoring when consuming transactional messages
Test
Additional failure testing for streams with bouncing brokers
有关升级的注意事项:在升级之前,请仔细阅读此版本的升级文档。其中讨论了关于不兼容的重要信息以及破坏性变化、性能变化以及可能影响你的 Kafka 生产部署的任何其他变更。
下载地址
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.2/kafka-0.11.0.2-src.tgz
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.2/kafka_2.11-0.11.0.2.tgz (Scala 2.11)
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.2/kafka_2.12-0.11.0.2.tgz (Scala 2.12)
Kafka 是一个高吞吐量的分布式发布订阅消息系统,值得注意的是,Kafka 1.0 已于 11 月 2 日发布。
来自:开源中国社区

