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

内容简介：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...

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

• [KAFKA-6564] - Fix broken links in Dockerfile

发行说明：

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

下载地址：

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

【声明】文章转载自：开源中国社区 [http://www.oschina.net]

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网

查看所有标签

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