Release Notes - Kafka - Version 0.10.2.2

Below is a summary of the JIRA issues addressed in the 0.10.2.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-4965] - set internal.leave.group.on.close to false in KafkaStreams
• [KAFKA-5118] - Improve message for Kafka failed startup with non-Kafka data in data.dirs
• [KAFKA-5242] - add max_number _of_retries to exponential backoff strategy
• [KAFKA-7009] - Mute logger for reflections.org at the warn level in system tests

Bug

• [KAFKA-4827] - Kafka connect: error with special characters in connector name
• [KAFKA-5150] - LZ4 decompression is 4-5x slower than Snappy on small batches / messages
• [KAFKA-5167] - streams task gets stuck after re-balance due to LockException
• [KAFKA-5205] - CachingSessionStore doesn't use the default keySerde.
• [KAFKA-5206] - RocksDBSessionStore doesn't use default aggSerde.
• [KAFKA-5230] - Recommended values for Connect transformations contain the wrong class name
• [KAFKA-5232] - Kafka broker fails to start if a topic containing dot in its name is marked for delete but hasn't been deleted during previous uptime
• [KAFKA-5241] - GlobalKTable does not checkpoint offsets after restoring state
• [KAFKA-5316] - Log cleaning can increase message size and cause cleaner to crash with buffer overflow
• [KAFKA-5345] - Some socket connections not closed after restart of Kafka Streams
• [KAFKA-5395] - Distributed Herder Deadlocks on Shutdown
• [KAFKA-5413] - Log cleaner fails due to large offset in segment file
• [KAFKA-5464] - StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG
• [KAFKA-5484] - Refactor kafkatest docker support
• [KAFKA-5623] - ducktape kafka service: do not assume Service contains num_nodes
• [KAFKA-5643] - Using _DUCKTAPE_OPTIONS has no effect on executing tests
• [KAFKA-5731] - Connect WorkerSinkTask out of order offset commit can lead to inconsistent state
• [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-6371] - FetchMetadata creates unneeded Strings on instantiation
• [KAFKA-6566] - SourceTask#stop() not called after exception raised in poll()
• [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-7021] - Source KTable checkpoint is not correct
• [KAFKA-7058] - ConnectSchema#equals() broken for array-typed default values