[09/43] git commit: KAFKA-829 Mirror maker needs to share the migration tool request channel; reviewed by Jun Rao

KAFKA-829 Mirror maker needs to share the migration tool request channel; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/66b10389 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/66b10389 Diff:

[27/43] git commit: KAFKA-860 Replica fetcher thread errors out and dies during rolling bounce of cluster; reviewed by Jun Rao, Jay Kreps

KAFKA-860 Replica fetcher thread errors out and dies during rolling bounce of cluster; reviewed by Jun Rao, Jay Kreps Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f9e36ca7 Tree:

[21/43] git commit: KAFKA-851 Broken handling of leader and isr request leads to incorrect high watermark checkpoint file; reviewed by Jun Rao and Swapnil Ghike

KAFKA-851 Broken handling of leader and isr request leads to incorrect high watermark checkpoint file; reviewed by Jun Rao and Swapnil Ghike Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1d3c343f Tree:

[38/43] git commit: KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun

KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/103aef8c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/103aef8c

[18/43] git commit: kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede

kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5a50f7e5 Tree:

[01/43] git commit: kafka-813; Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao

Updated Branches: refs/heads/trunk 3b470f56b - 2cda5d1fc kafka-813; Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/28ee7855

[15/43] git commit: KAFKA-840 Controller tries to perform preferred replica election on failover before state machines have started up; reviewed by Neha Narkhede

KAFKA-840 Controller tries to perform preferred replica election on failover before state machines have started up; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a9ce73cf Tree:

[41/43] git commit: KAFKA-892 Change request log to include request completion not handling; reviewed by Joel Koshy

KAFKA-892 Change request log to include request completion not handling; reviewed by Joel Koshy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/988d4d8e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/988d4d8e Diff:

[03/43] git commit: kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede

kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e367f3ff Tree:

[02/43] git commit: kafka-813; (add the missing file) Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao

kafka-813; (add the missing file) Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/df221297 Tree:

[32/43] git commit: KAFKA-870 hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller; reviewed by Neha Narkhede

KAFKA-870 hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1976ce80 Tree:

[04/43] git commit: kafka-791; Fix validation bugs in System Test; patched by John Fung; reviewed by Jun Rao

kafka-791; Fix validation bugs in System Test; patched by John Fung; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/26c50fac Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/26c50fac Diff:

[35/43] git commit: kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede

kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6e640e35 Tree:

[16/43] git commit: kafka-827; improve list topic output format; patched by Jun Rao; reviewed by Neha Narkhede

kafka-827; improve list topic output format; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3c27988c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3c27988c Diff:

[10/43] git commit: KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao

KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1d5e95f6 Tree:

[19/43] git commit: KAFKA-840 Post commit

KAFKA-840 Post commit Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3ead78b9 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3ead78b9 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3ead78b9 Branch:

[07/43] git commit: KAFKA-828 Preferred Replica Election does not delete the admin path on controller failover; reviewed by Neha Narkhede and Jun Rao

KAFKA-828 Preferred Replica Election does not delete the admin path on controller failover; reviewed by Neha Narkhede and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2fe3f9fe Tree:

[06/43] git commit: kafka-819; System Test : Add validation of log segment index to offset; patched by John Fung; reviewed by Jun Rao

kafka-819; System Test : Add validation of log segment index to offset; patched by John Fung; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f570cce1 Tree:

[22/43] git commit: KAFKA-849 Bug in controller's startup/failover logic fails to update in memory leader and isr cache causing other state changes to work incorrectly; reviewed by Jun Rao and Swapnil

KAFKA-849 Bug in controller's startup/failover logic fails to update in memory leader and isr cache causing other state changes to work incorrectly; reviewed by Jun Rao and Swapnil Ghike Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[14/43] git commit: trivial fix to print key properly in DumpLogSegments

trivial fix to print key properly in DumpLogSegments Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/06911384 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/06911384 Diff:

[11/43] git commit: kafka-832; 0.8 Consumer prevents rebalance if consumer thread is blocked or slow; patched by Jun Rao; reviewed by Neha Narkhede

kafka-832; 0.8 Consumer prevents rebalance if consumer thread is blocked or slow; patched by Jun Rao; reviewed by Neha Narkhede Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6e05d7da Tree:

[12/43] git commit: KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao and Swapnil Ghike

KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao and Swapnil Ghike Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9f6af315 Tree:

[08/43] git commit: Missing file from KAFKA-828

Missing file from KAFKA-828 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/be3ce147 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/be3ce147 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/be3ce147 Branch: