Apache Kafka 1.0.2 发布,功能改进和修复

栏目: 服务器 · Apache · 发布时间: 6年前

内容简介:Apache Kafka 1.0.2 已发布,包含 27 个 JIRA 的修复和改进,包括一些关键 bug 修复。ImprovementBug

Apache Kafka 1.0.2 已发布,包含 27 个 JIRA 的修复和改进,包括一些关键 bug 修复。

Improvement

  • [ KAFKA-6364 ] - Add Second Check for End Offset During Restore

  • [ KAFKA-6634 ] - Delay initiating the txn on producers until initializeTopology with EOS turned on

  • [ KAFKA-6772 ] - Broker should load credentials from ZK before requests are allowed

Bug

  • [ KAFKA-5996 ] - JsonConverter generates "Mismatching schema" DataException

  • [ KAFKA-6054 ] - ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

  • [ KAFKA-6360 ] - RocksDB segments not removed when store is closed causes re-initialization to fail

  • [ KAFKA-6536 ] - Streams quickstart pom.xml is missing versions for a bunch of plugins

  • [ KAFKA-6566 ] - SourceTask#stop() not called after exception raised in poll()

  • [ KAFKA-6568 ] - LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

  • [ KAFKA-6661 ] - Sink connectors that explicitly 'resume' topic partitions can resume a paused task

  • [ KAFKA-6711 ] - GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

  • [ KAFKA-6739 ] - Down-conversion fails for records with headers

  • [ KAFKA-6747 ] - kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION

  • [ KAFKA-6748 ] - Scheduler cannot be cancelled from Punctuator

  • [ KAFKA-6782 ] - GlobalKTable GlobalStateStore never finishes restoring when consuming aborted messages

  • [ KAFKA-6857 ] - LeaderEpochFileCache.endOffsetFor() should check for UNDEFINED_EPOCH explicitly

  • [ KAFKA-6906 ] - Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

  • [ KAFKA-6925 ] - Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl

  • [ KAFKA-6937 ] - In-sync replica delayed during fetch if replica throttle is exceeded

  • [ KAFKA-6975 ] - AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

  • [ KAFKA-7012 ] - Performance issue upgrading to kafka 1.0.1 or 1.1

  • [ KAFKA-7021 ] - Source KTable checkpoint is not correct

  • [ KAFKA-7058 ] - ConnectSchema#equals() broken for array-typed default values

  • [ KAFKA-7104 ] - ReplicaFetcher thread may die because of inconsistent log start offset in fetch response

Task

  • [ KAFKA-6854 ] - Log cleaner fails with transaction markers that are deleted during clean

  • [ KAFKA-6917 ] - Request handler deadlocks attempting to acquire group metadata lock

Test

发行说明:

https://www.apache.org/dist/kafka/1.0.2/RELEASE_NOTES.html

下载地址:

https://kafka.apache.org/downloads#1.0.2


以上所述就是小编给大家介绍的《Apache Kafka 1.0.2 发布,功能改进和修复》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

单元测试之道Java版

单元测试之道Java版

David Thomas、Andrew Hunt / 陈伟柱、陶文 / 电子工业 / 2005-1 / 25.00元

程序员修炼三部曲丛书包含了四本书,介绍了每个注重实效的程序员和成功团队所必备的一些工具。 注重实效的程序员都会利用反馈来指导开发,并驱动个人的开发流程。编码的时候,最有用的反馈来自于“单元测试”。 为了测试一座桥梁,不会只在晴朗的天气,开一辆汽车从桥中间穿过,就认为已经完成了对桥梁的测试。然而许多程序员却正在使用这种测试方法——把这种一次顺利通过称为“测试”。事实上,注重实效的程序员应......一起来看看 《单元测试之道Java版》 这本书的介绍吧!

Markdown 在线编辑器
Markdown 在线编辑器

Markdown 在线编辑器

正则表达式在线测试
正则表达式在线测试

正则表达式在线测试

HEX HSV 转换工具
HEX HSV 转换工具

HEX HSV 互换工具