## apache/kafka — kafka-0.7.2-incubating-candidate-5…show

_892+ commits._

### Features
- **trivial change to add byte serializer to ProducerPerformance; patched by Jun Rao** (d4629df)
- **KAFKA-1723; make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jay Kreps and Jun Rao** (9b6744d)
- **kafka-1797; (missed parametric in a few files) add the serializer/deserializer api to the new java client; patched by Jun Rao** (828b808)
- **kafka-1797; (addressing Manikumar Reddy's comment) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Manikumar Reddy and Neha Narkhede** (f71933e)
- **kafka-1797; add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede** (03ad248)
- **kafka-1642; [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network connection is lost; patched by Ewen Cheslack-Postava; reviewed by Guozhang Wang and Jun Rao** (8bd5738)
- **KAFKA-1725 Configuration file bugs in system tests add noise to output and break a few tests; reviewed by Neha Narkhede** (caf4787)
- **KAFKA-979 Add jitter for time based rolling; reviewed by Neha Narkhede and Joel Koshy** (75fb44d)
- **KAFKA-1471 Add producer unit tests for LZ4 and LZ4HC compression codecs; patched by James Oliver; reviewed by Neha Narkhede** (da2c7cd)
- **KAFKA-1692 Include client ID in new producer IO thread name; reviewed by Neha Narkhede** (fcfeba7)
- **kafka-1468; (followup) add back inadventently removed commit; patched by Guozhang Wang; reviewed by Jun Rao** (5fcc374)
- **KAFKA-1597 New metrics: ResponseQueueSize and BeingSentResponses; reviewed by Neha Narkhede and Jun Rao** (cf0f575)
- **kafka-1609; New producer metadata response handling should only exclude a PartitionInfo when its error is LEADER_NOT_AVAILABLE; patched by Dong Lin; reviewed by Jun Rao** (aa775a1)
- **kafka-1562; kafka-topics.sh alter add partitions resets cleanup.policy; patched by Jonathan Natkins; reviewed by Jun Rao** (f8d521a)
- **kafka-1542; normal IOException in the new producer is logged as ERROR; patched by David Corley; reviewed by Jun Rao** (fa34841)
- **kafka-1462; Add new request and response formats for the new consumer and coordinator communication; patched by Jun Rao; reviewed by Guozhang Wang and Jay Kreps** (fc0e03f)
- **KAFKA-1512 Add per-ip connection limits.** (8e444a3)
- **KAFKA-1498 Follow-up: add metric on avg record size.** (e3dfad3)
- **KAFKA-1291 Add wrapper scripts and usage information to each command.** (6b0ae4b)
- **KAFKA-1326 Refactor Sender to support consumer.** (548d1ba)
- **KAFKA-1488; new metrics for measuring the ratio when the new producer is block for space allocation; patched by Jun Rao; reviewed by Guozhang Wang and Joel Koshy** (dcc8840)
- **KAFKA-1472; Add the compression ratio metrics in the new producer; patched by Dong Lin; reviewed by Guozhang Wang and Jun Rao** (bb01847)
- **KAFKA-1443 Add delete topic option to topic commands; reviewed by Neha Narkhede** (ee4456a)

### Fixes
- **KAFKA-1512 Fixes for limit the maximum number of connections per ip address patch by Jeff Holoman reviewed by Jay Krepps and Gwen Shapira** (367ee76)
- **kafka-1797; (delta follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede** (fec9f32)
- **kafka-1797; (follow-up patch) add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Jay Kreps** (f32e5ce)
- **kafka-1642; (followup patch) [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network connection is lost; patched by Ewen Cheslack-Postava; patched by Ewen Cheslack-Postava; reviewed by Jun Rao** (5332958)
- **KAFKA-1725: New test files, patch part 2** (a75a295)
- **kafka-1670 (followup to fix system tests); Corrupt log files for segment.bytes values close to Int.MaxInt; patched by Sriharsha Chintalapani; reviewed by Jun Rao** (ca0a956)
- **KAFKA-1662 gradle release issue permgen space patch by Sriharsha Chintalapani reviewed by Joe Sein and branch release version change** (108f6d7)
- **KAFKA-1577; Follow-up patch: Fix exception in connection-quotas while shutting down by forcing key-cancellation; reviewed by Joel Koshy and Neha Narkhede** (54b6419)
- **KAFKA-1490 remove gradlew initial setup output from source distribution patch by Ivan Lyutov reviewed by Joe Stein** (db0b0b8)
- **KAFKA-1490 remove gradlew initial setup output from source distribution patch by Ivan Lyutov reviewed by Joe Stein** (d2d1ef3)
- **KAFKA-1502 source jar is empty patch by Jun Rao reviewed by Joe Stein** (3abe340)
- **KAFKA-1485 Upgrade to Zookeeper 3.4.6 and create shim for ZKCLI so system tests can run patch by Gwen Shapira reviewed by Joe Stein and Jun Rao** (2cdc83e)
- **kafka-1598; Fix variable typo in Kafka main class; patched by Jarek Jarcec Cecho; reviewed by Jun Rao** (f402b7a)
- **KAFKA-1576: Make delete topic command a little more user-friendly. Patch from Gwen Shapira.** (7802255)
- **KAFKA-1560 Make arguments to jira-python API more explicit in kafka-patch-review's get_jira(); reviewed by Neha Narkhede** (caf256a)
- **KAFKA-1485 Upgrade to Zookeeper 3.4.6 patch by Gwen Shapira reviewed by Joe Stein** (7a67a72)
- **KAFKA-1550; Patch review tool should use git format-patch for patch generation; reviewed by Guozhang Wang and Joel Koshy** (09690e3)
- **kafka-1542 (trivail followup patch to fix NullPointerException); normal IOException in the new producer is logged as ERROR; patched by Jun Rao** (50f2b24)
- **KAFKA-1544 Log cleaner takes a long time to shut down. Patch from Manikumar Reddy.** (db41f98)
- **kafka-1462 (followup patch); Add new request and response formats for the new consumer and coordinator communication; patched by Jun Rao; reviewed by Jay Kreps** (014b700)
- **KAFKA-1180 WhiteList topic filter gets a NullPointerException on complex Regex patch by Joe Stein, reviewed by Joel Koshy** (592678e)
- **KAFKA-1258 Automatically delete temporary directories with a shutdown hook during tests to avoid leaking temp files. Patch by Manikumar Reddy.** (4b3d03e)
- **KAFKA-1515 Producer can hang during metadata updates. Patch by Guozhang.** (83a9aa5)
- **kafka-1406; Fix scaladoc/javadoc warnings; patched by Alan Lee; reviewed by Jun Rao** (8034390)
- **kafka-1325; Fix inconsistent per topic log configs; patched by Manikumar Reddy; reviewed by Jun Rao** (420628d)
- **KAFKA-1515 Fix a bug that could result in blocking for a long period of time in the producer. Patch from Guozhang Wang.** (cd3ce27)
- **KAFKA-1519 Make it possible to disable the line seperator in the console consumer. Patch from Gwen Shapira.** (6de56b3)
- **KAFKA-1498 Misc. producer performance enhancements. Patch from Guozhang.** (f1c6e97)
- **KAFKA-1316 Follow-up patch for concurrent modification exception.** (d0c019a)
- **KAFKA-1382 follow up patch; reviewed by Neha Narkhede** (dd048d8)
- **KAFKA-1459 follow up minor patch** (26eb127)
- **trival fix to remove reference of sbt in README** (e73e90e)

### Backend
- **change build version to 0.8.2.0** (a643be6)
- **kafka-1711; WARN Property topic is not valid when running console producer; patched by Joe Crobak; reviewed by Jun Rao** (4e584de)
- **KAFKA-1841; OffsetCommitRequest API - timestamp field is not versioned; patched by Jun Rao; reviewed by Joel Koshy** (432d397)
- **KAFKA-1819 Cleaner gets confused about deleted and re-created topics; reviewed by Neha Narkhede** (8d5d459)
- **kafka-1851; OffsetFetchRequest returns extra partitions when input only contains unknown partitions; patched by Jun Rao; reviewed by Neha Narkhede** (f88db16)
- **KAFKA-1624; bump up default scala version to 2.11.4 to compile with java 8; reviewed by Joe Stein, Gwen Shapira and Joel Koshy** (79d16dc)
- **kafka-1799; ProducerConfig.METRIC_REPORTER_CLASSES_CONFIG doesn't work; patched by Manikumar Reddy; reviewed by Jun Rao** (bd212b7)
- **kafka-1743; ConsumerConnector.commitOffsets in 0.8.2 is not backward compatible; patched by Manikumar Reddy; reviewed by Jun Rao** (fbecd48)
- **kafka-17693; javadoc should only include client facing packages; patched by Jun Rao; reviewed by Neha Narkhede** (00dfa89)
- **kafka-1481; Stop using dashes AND underscores as separators in MBean names; patched by Vladimir Tretyakov; reviewed by Joel Koshy and Jun Rao** (117a02d)
- **kafka-1721; Snappy compressor is not thread safe; patched by Ewen Cheslack-Postava; reviewed by Jun Rao** (7e1907e)
- **KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdown commands to the same data chunk queue; reviewed by Joel Koshy and Guozhang Wang** (de6d4e4)
- **kafka-1733; Producer.send will block indeterminately when broker is unavailable; patched by Marc Chung; reviewed by Jun Rao** (91f8ce7)
- **KAFKA-1742; ControllerContext removeTopic does not correctly update state; reviewed by Joel Koshy, Guozhang Wang and Neha Narkhede** (383ac3e)
- **kafka-1738; Partitions for topic not created after restart from forced shutdown; patched by Jun Rao; reviewed by Neha Narkhede** (80eb04f)
- **KAFKA-1647; Create replicas on follower transition even if leader is** (2ec356f)
- **KAFKA-1732 DumpLogSegments tool fails when path has a '.'; reviewed by Neha Narkhede** (9be9a80)
- **KAFKA-1719 Make mirror maker exit when one consumer/producer thread exits; reviewed by Neha Narkhede, Joel Koshy and Guozhang Wang** (5e071cd)
- **KAFKA-1653 Duplicate broker ids allowed in replica assignment; reviewed by Neha Narkhede** (c2dadda)
- **changed release version prior to candidate release** (a6170d4)
- **kafka-1717; remove netty dependency through ZK 3.4.x; patched by Jun Rao; reviewed by Sriharsha Chintalapani and Neha Narkhede** (eb7ac9e)
- **KAFKA-1108 When controlled shutdown attempt fails, the reason is not always logged; reviewed by Neha Narkhede** (91d828a)
- **kafka-1671; uploaded archives are missing for Scala version 2.11; patched by Ivan Lyutov; reviewed by Jun Rao** (5771f15)
- **kafka-1493; Use a well-documented LZ4 compression format and remove redundant LZ4HC option; patched by James Oliver; reviewed by Jun Rao** (ee1bab7)
- **KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group; reviewed by Neha Narkhede and Joel Koshy** (f084127)
- **Reverting KAFKA-1637 on 0.8.2 since it was only reverted on trunk** (ede0ec3)
- **KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group; reviewed by Neha Narkhede** (5257e9d)
- **kafka-1555; provide strong consistency with reasonable availability; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao** (4546b9d)
- **KAFKA-1305. Controller can hang on controlled shutdown with auto leader balance enabled; reviewed by Neha Narkhede and Jun Rao** (133a4fb)
- **kafka-1699; autoRebalanceScheduler.shutdown() causes deadlock while controller shutting down; patched by Sriharsha Chintalapani; reviewed by Jun Rao** (c63e062)
- **kafka-1558; AdminUtils.deleteTopic does not work; patched by Sriharsha Chintalapani; reviewed by Jun Rao** (841d441)
- **kafka-1681; Newly elected KafkaController might not start deletion of pending topics; patched by Sriharsha Chintalapani; reviewed by Jun Rao** (3d6df54)
- **kafka-1663; Controller unable to shutdown after a soft failure; patched by Sriharsha Chintalapani; reviewed by Neha Narkhede and Jun Rao** (5e45b55)
- **kafka-1644; Inherit FetchResponse from RequestOrResponse; patched by Anton Karamanov; reviewed by Jun Rao** (1ac8df1)
- **kafka-1670; Corrupt log files for segment.bytes values close to Int.MaxInt; patched by Sriharsha Chintalapani; reviewed by Jay Kreps and Jun Rao** (db0d76b)
- **kafka-1673; potential java.lang.IllegalStateException in BufferPool.allocate(); patched by Jun Rao; reviewed by Jay Kreps** (f433581)
- **kafka-1618 (followup); Exception thrown when running console producer with no port number for the broker; patched by Balaji Seshadri; reviewed by Jun Rao** (6861d46)
- **KAFKA-1618 Exception thrown when running console producer with no port number for the broker; reviewed by Neha Narkhede** (a9c7d77)
- **KAFKA-589 Clean shutdown after startup connection failure; reviewed by Neha Narkhede** (9c17747)
- **KAFKA-404 When using chroot path, create chroot on startup if it doesn't exist; reviewed by Neha Narkhede** (f750dba)
- **kafka-1645; some more jars in our src release; patched by Joe Stein; reviewed by Jun Rao** (084566b)
- **trivial change to README to make the gradle wrapper download clearer** (27bc372)
- **kafka-1622; project shouldn't require signing to build; patched by Ivan Lyutov; reviewed by Jun Rao** (6d70575)
- **KAFKA-1282 Disconnect idle socket connection in Selector; reviewed by Neha Narkhede and Jun Rao** (8eac7d7)
- **kafka-1123; Broker IPv6 addresses parsed incorrectly; patched by Krzysztof Szafrański; reviewed by Jun Rao** (be5edd2)
- **kafka-1620; Make kafka api protocol implementation public; patched by Anton Karamanov; reviewed by Jun Rao** (c892c08)
- **trivial change to javadoc for makeLeaders(); patched by Lantao Jin** (a1423ae)
- **KAFKA-1496 Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument; reviewed by Neha Narkhede** (d677701)
- **KAFKA-847 kafka appender layout does not work for kafka 0.7.1; reviewed by Neha Narkhede and Jun Rao** (3e8854c)
- **KAFKA-1611 Improve system test configuration; reviewed by Neha Narkhede and Guozhang Wang** (cb6a159)
- **kafka-1369; snappy version update 1.1.x; patched by Roger Hoover; reviewed by Jun Rao** (f5ab8e1)
- **kafka-1419 (followup); cross build for scala 2.11; patched by Stevo Slavic; reviewed by Jun Rao** (f9d9b38)
- **kafka-1619; perf dir can be removed; patched by Jun Rao; reviewed by Guozhang Wang, Neha Narkhede and Stevo Slavic** (8d0ab1d)
- **KAFKA-1147 Consumer socket timeout should be greater than fetch max wait; reviewed by Neha Narkhede and Jun Rao** (3d3c544)
- **KAFKA-1510; Do full (unfiltered) offset commits when offsets storage is set to Kafka; reviewed by Joel Koshy** (e22f8ed)
- **kafka-1616; Purgatory Size and Num.Delayed.Request metrics are incorrect; patched by Guozhang Wang; reviewed by Jun Rao** (ffb81a5)
- **KAFKA-1485 Upgrade to Zookeeper 3.4.6 missing file** (ae24141)
- **KAFKA-687; Provide a roundrobin partition assignment strategy that considers partitions from all topics; reviewed by Jun Rao and Guozhang Wang.** (953e35b)
- **KAFKA-1577; Swallow errors from connection-quotas in closing sockets on shutdown; reviewed by Joel Koshy** (538122f)
- **kafka-1603; MirrorMaker consumer does not put the message key into ProducerRecord; patched by Jiangjie Qin; reviewed by Jun Rao** (a30491a)
- **KAFKA-1580; Reject producer requests to internal topics; reviewed by Joel Koshy and Neha Narkhede** (c6f08b6)
- **KAFKA-1582; System Test should wait for producer to finish; reviewed by Joel Koshy and Guozhang Wang** (d678449)
- **kafka-1567; Metric memory leaking after closing the clients; patched by Jiangjie Qin; reviewed by Guozhang Wang and Jun Rao** (a552d4b)
- **kafka-1567; Metric memory leaking after closing the clients; patched by Jiangjie Qin; reviewed by Guozhang Wang and Jun Rao** (aa70a7d)
- **Revert KAFKA-1485 Upgrade to Zookeeper 3.4.6 since system tests are failing** (48cc2dc)
- **trunk is the 0.8.2 snapshot** (8a8c490)
- **kafka-1574; unit tests can hang on socketserver shutdown; patched by Jun Rao; reviewed by Jay Kreps and Guozhang Wang** (0607953)
- **kafka-1419; cross build for scala 2.11; patched by Ivan Lyutov; reviewed by Joe Stein and Jun Rao** (4d07597)
- **kafka-1578; Controller should de-register all listeners upon designation; patched by Guozhang Wang; reviewed by Jun Rao** (c9894fb)
- **kafka-1430; Purgatory redesign; patched by Guozhang Wang; reviewed by Jun Rao** (0dc243b)
- **trivial change to remove a compilation warning; patched by Jun Rao** (0386790)
- **kafka-1571; MetadataTest hangs; patched by Jun Rao; reviewed by Guozhang Wang** (1d2e776)
- **kafka-1451; Broker stuck due to leader election race; patched by Manikumar Reddy; reviewed by Jun Rao** (a01a101)
- **kafka-1414; Speedup broker startup after hard reset; patched by Anton Karamanov; reviewed by Jay Kreps and Jun Rao** (f489493)
- **kafka-1549; dead brokers coming in the TopicMetadataResponse; patched by Nicu Marasoiu; reviewed by Jun Rao** (7f2278f)
- **KAFKA-1483 Split Brain about Leader Partitions; reviewed by Guozhang, Jun and Neha** (d9e5080)
- **kafka-1192; Enable DumpLogSegments tool to deserialize messages; patched by Manikumar Reddy; reviewed by Guozhang Wang and Jun Rao** (3f1a9c4)
- **kafka-1533; transient unit test failure in ProducerFailureHandlingTest; reviewed by Guozhang Wang; reviewed by Jun Rao** (ff05e9b)
- **KAFKA-1539 Fsync offset checkpoint file after writing.** (1e4b084)
- **KAFKA-1535 Have the metadata response contain all alive brokers rather than just the ones needed for the given topics.** (4ebcdfd)
- **kafka-1531; zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball; patched by Manikumar Reddy; reviewed by Jun Rao** (b428d8c)
- **kafka-1529; transient unit test failure in testAutoCreateAfterDeleteTopic; patched by Jun Rao; reviewed by Guozhang Wang and Neha Narkhede** (3e6b386)
- **kafka-1513; Cleanup KafkaServerStartable code; patched by Evgeny Vereshchagin; reviewed by Jun Rao** (b1a1cae)
- **kafka-1503; all partitions are using same broker as their leader after broker is down;  patched by Jianwen Wang; reviewed by Guozhang Wang and Jun Rao** (2a4718c)
- **KAFKA-1308 Publish jar of test utilities to Maven** (b8d87d0)
- **KAFKA-1491; Always read coordinator information in consumer metadata response; reviewed by Neha Narkhede.** (c4b9564)
- **KAFKA-1096 An old controller coming out of long GC could update its epoch to the latest controller's epoch; reviewed by Neha Narkhede** (62f2087)
- **KAFKA-1382. Update zkVersion on partition state update failures; reviewed by Neha Narkhede** (dee1645)
- **KAFKA-1298 (followup); Controlled shutdown tool doesn't seem to work out of the box;  patched by Sriharsha Chintalapani; reviewed by Jun Rao** (b04a3be)
- **kafka-1438 (follow-up); Migrate client tools out of perf;  patched by Sriharsha Chintalapani; reviewed by Jun Rao** (6d19922)
- **KAFKA-1469 Util.abs function does not return correct absolute values for negative values; patched by Guozhang Wang and Neha Narkhede** (d300717)
- **KAFKA-1438 Migrate client tools out of perf; reviewed by Neha Narkhede** (1363ed7)
- **kafka-1473; transient unit test failure in testRequestHandlingDuringDeleteTopic;  patched by Guozhang Wang; reviewed by Jun Rao** (df449a2)
- **kafka-924 (follow-up); Specify console consumer properties via a single --property command line parameter;;  patched by Sriharsha Chintalapani; reviewed by Jun Rao** (3a048e8)
- **KAFKA-1468 Misc. improvements from benchmarking.** (02311c0)

_Recap by [Repo Wrapped](https://repowrapped.com/gh/apache/kafka?utm_source=github-action)._