Release Notes - Kafka - Version 0.9.0.1

Sub-task

[KAFKA-2058] - ProducerTest.testSendWithDeadBroker transient failure
[KAFKA-2455] - Test Failure: kafka.consumer.MetricsTest > testMetricsLeak
[KAFKA-2655] - Consumer.poll(0)'s overhead too large
[KAFKA-2977] - Transient Failure in kafka.log.LogCleanerIntegrationTest.cleanerTest
[KAFKA-3103] - Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack

Bug

[KAFKA-1862] - Pass in the Time object into OffsetManager
[KAFKA-2143] - Replicas get ahead of leader and fail
[KAFKA-2478] - KafkaConsumer javadoc example seems wrong
[KAFKA-2578] - Client Metadata internal state should be synchronized
[KAFKA-2589] - Documentation bug: the default value for the "rebalance.backoff.ms" property is not specified correctly
[KAFKA-2676] - Incorrect package name in tests (unit and integration prefix)
[KAFKA-2695] - Handle null string/bytes protocol primitives
[KAFKA-2752] - Add clean bounce system test for distributed Copycat
[KAFKA-2799] - WakupException thrown in the followup poll() could lead to data loss
[KAFKA-2877] - Messages sometimes not delivered by new consumer after Kafka restart
[KAFKA-2880] - Fetcher.getTopicMetadata NullPointerException when broker cannot be reached
[KAFKA-2893] - Add Negative Partition Seek Check
[KAFKA-2899] - Should log unexpected exceptions thrown when reading from local log
[KAFKA-2913] - GroupMetadataManager unloads all groups in removeGroupsForPartitions
[KAFKA-2926] - [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer
[KAFKA-2936] - Socket server selector can stuck on one send in tight loop.
[KAFKA-2937] - Topics marked for delete in Zookeeper may become undeletable
[KAFKA-2938] - Socket server may throw IllegalStateException
[KAFKA-2942] - Inadvertent auto-commit when pre-fetching can cause message loss
[KAFKA-2950] - Performance regression in producer
[KAFKA-2972] - ControlledShutdownResponse always serialises `partitionsRemaining` as empty
[KAFKA-2973] - Fix leak of child sensors on remove
[KAFKA-2974] - `==` is used incorrectly in a few places in Java code
[KAFKA-2978] - Topic partition is not sometimes consumed after rebalancing of consumer group
[KAFKA-2981] - Fix javadoc in KafkaConsumer
[KAFKA-2990] - NoSuchMethodError when Kafka is compiled with 1.8 and run on 1.7
[KAFKA-2993] - compression-rate-avg always returns 0 even with compression.type being set
[KAFKA-3003] - The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.
[KAFKA-3014] - Integer overflow causes incorrect node iteration in leastLoadedNode()
[KAFKA-3055] - JsonConverter mangles schema during serialization (fromConnectData)
[KAFKA-3068] - NetworkClient may connect to a different Kafka cluster than originally configured
[KAFKA-3075] - java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets
[KAFKA-3095] - No documentation on format of sasl.kerberos.principal.to.local.rules
[KAFKA-3098] - "partition.assignment.strategy" appears twice in documentation
[KAFKA-3122] - Memory leak in `Sender.completeBatch` on TOPIC_AUTHORIZATION_FAILED
[KAFKA-3134] - Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"
[KAFKA-3141] - kafka-acls.sh throws ArrayIndexOutOfBoundsException for an invalid authorizer-property
[KAFKA-3152] - kafka-acl doesn't allow space in principal name
[KAFKA-3157] - Mirror maker doesn't commit offset with new consumer when there is no more messages
[KAFKA-3159] - Kafka consumer 0.9.0.0 client poll is very CPU intensive under certain conditions
[KAFKA-3169] - Kafka broker throws OutOfMemory error with invalid SASL packet
[KAFKA-3170] - Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1
[KAFKA-3179] - Kafka consumer delivers message whose offset is earlier than sought offset.
[KAFKA-3194] - Validate security.inter.broker.protocol against the advertised.listeners protocols
[KAFKA-3198] - Ticket Renewal Thread exits prematurely due to inverted comparison
[KAFKA-3216] - "Modifying topics" section incorrectly says you can't change replication factor.

Improvement

[KAFKA-2221] - Log the entire cause which caused a reconnect in the SimpleConsumer
[KAFKA-2761] - Enable passing regex via whitelist for new-consumer in ConsoleConsumer
[KAFKA-2882] - Add constructor cache for Snappy and LZ4 Output/Input stream in Compressor.java
[KAFKA-2924] - Add offsets/group metadata decoder so that DumpLogSegments can be used with the offsets topic
[KAFKA-2940] - Make available to use any Java options at startup scripts
[KAFKA-2957] - Fix typos in Kafka documentation
[KAFKA-2988] - Change default configuration of the log cleaner
[KAFKA-3002] - Make available to specify hostname with Uppercase at broker list
[KAFKA-3010] - include error code when logging an error when ack = 0
[KAFKA-3012] - Avoid reserved.broker.max.id collisions on upgrade
[KAFKA-3029] - Make class org.apache.kafka.common.TopicPartition Serializable
[KAFKA-3045] - ZkNodeChangeNotificationListener shouldn't log interrupted exception as error
[KAFKA-3048] - incorrect property name ssl.want.client.auth
[KAFKA-3051] - security.protocol documentation is inaccurate
[KAFKA-3052] - broker properties get logged twice if acl is enabled
[KAFKA-3100] - Broker.createBroker should work if json is version > 2, but still compatible
[KAFKA-3164] - Document client and mirrormaker upgrade procedure/requirements
[KAFKA-3166] - Disable SSL client authentication for SASL_SSL security protocol
[KAFKA-3191] - Improve offset committing JavaDoc in KafkaConsumer
[KAFKA-3234] - Minor documentation edits: clarify minISR; some topic-level configs are missing