Release Notes - Kafka - Version 1.0.2

Below is a summary of the JIRA issues addressed in the 1.0.2 release of Kafka. For full documentation of the release, a guide to get started, and information about the project, see the Kafka project site.

Note about upgrades: Please carefully review the upgrade documentation for this release thoroughly before upgrading your cluster. The upgrade notes discuss any critical information about incompatibilities and breaking changes, performance changes, and any other changes that might impact your production deployment of Kafka.

The documentation for the most recent release can be found at http://kafka.apache.org/documentation.html.

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