Release Notes - Kafka - Version 1.0.1

Below is a summary of the JIRA issues addressed in the 1.0.1 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-5987] - Kafka metrics templates used in document generation should maintain order of tags
• [KAFKA-6102] - Consolidate MockTime implementations between connect and clients
• [KAFKA-6157] - Fix repeated words words in JavaDoc and comments.
• [KAFKA-6172] - Cache lastEntry in TimeIndex to avoid unnecessary disk access
• [KAFKA-6175] - AbstractIndex should cache index file to avoid unnecessary disk access during resize()
• [KAFKA-6205] - Have State Stores Restore Before Initializing Toplogy
• [KAFKA-6258] - SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data
• [KAFKA-6274] - Improve KTable Source state store auto-generated names

Bug

• [KAFKA-4263] - QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds
• [KAFKA-4767] - KafkaProducer is not joining its IO thread properly
• [KAFKA-4827] - Kafka connect: error with special characters in connector name
• [KAFKA-6069] - Streams metrics tagged incorrectly
• [KAFKA-6148] - ClassCastException in BigQuery connector
• [KAFKA-6164] - ClientQuotaManager threads prevent shutdown when encountering an error loading logs
• [KAFKA-6166] - Streams configuration requires consumer. and producer. in order to be read
• [KAFKA-6167] - Timestamp on streams directory contains a colon, which is an illegal character
• [KAFKA-6174] - Add methods in Options classes to keep binary compatibility with 0.11
• [KAFKA-6179] - RecordQueue.clear() does not clear MinTimestampTracker's maintained list
• [KAFKA-6185] - Selector memory leak with high likelihood of OOM in case of down conversion
• [KAFKA-6190] - GlobalKTable never finishes restoring when consuming transactional messages
• [KAFKA-6210] - IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version
• [KAFKA-6214] - Using standby replicas with an in memory state store causes Streams to crash
• [KAFKA-6238] - Issues with protocol version when applying a rolling upgrade to 1.0.0
• [KAFKA-6252] - A metric named 'XX' already exists, can't register another one.
• [KAFKA-6256] - Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache
• [KAFKA-6260] - AbstractCoordinator not clearly handles NULL Exception
• [KAFKA-6261] - Request logging throws exception if acks=0
• [KAFKA-6269] - KTable state restore fails after rebalance
• [KAFKA-6277] - Make loadClass thread-safe for class loaders of Connect plugins
• [KAFKA-6287] - Inconsistent protocol type for empty consumer groups
• [KAFKA-6288] - Broken symlink interrupts scanning the plugin path
• [KAFKA-6289] - NetworkClient should not return internal failed api version responses from poll
• [KAFKA-6302] - Topic can not be recreated after it is deleted
• [KAFKA-6307] - mBeanName should be removed before returning from JmxReporter#removeAttribute()
• [KAFKA-6308] - Connect: Struct equals/hashCode method should use Arrays#deep* methods
• [KAFKA-6319] - kafka-acls regression for comma characters (and maybe other characters as well)
• [KAFKA-6323] - punctuate with WALL_CLOCK_TIME triggered immediately
• [KAFKA-6354] - Update KStream JavaDoc with regard to KIP-182
• [KAFKA-6366] - StackOverflowError in kafka-coordinator-heartbeat-thread
• [KAFKA-6367] - Fix StateRestoreListener To Use Correct Batch Ending Offset
• [KAFKA-6378] - NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null
• [KAFKA-6398] - Non-aggregation KTable generation operator does not construct value getter correctly
• [KAFKA-6422] - When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown
• [KAFKA-6467] - Enforce layout of dependencies within a Connect plugin to be deterministic
• [KAFKA-6504] - Connect: Some per-task-metrics not working
• [KAFKA-6529] - Broker leaks memory and file descriptors after sudden client disconnects

Test

• [KAFKA-6215] - KafkaStreamsTest fails in trunk
• [KAFKA-6300] - SelectorTest may fail with ConcurrentModificationException

Sub-task

• [KAFKA-6118] - Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials