kafka git commit: kafka-2235; LogCleaner offset map overflow; patched by Ivan Simoneko; reviewed by Jun Rao

2015-06-22 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk cf28f8939 - dc54055d0 kafka-2235; LogCleaner offset map overflow; patched by Ivan Simoneko; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: kafka-2290; OffsetIndex should open RandomAccessFile consistently; patched by Chris Black; reviewed by Jun Rao

2015-06-22 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 16ecf9806 - cf28f8939 kafka-2290; OffsetIndex should open RandomAccessFile consistently; patched by Chris Black; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

kafka git commit: KAFKA-2245; Add response tests for consumer coordinator; reviewed by Joel Koshy

2015-06-22 Thread jjkoshy
Repository: kafka Updated Branches: refs/heads/trunk dc54055d0 - 1eac3ceaf KAFKA-2245; Add response tests for consumer coordinator; 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/1eac3cea Tree:

[1/2] kafka git commit: kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Post

2015-06-22 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 2270a7537 - b6d326b08 http://git-wip-us.apache.org/repos/asf/kafka/blob/b6d326b0/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java -- diff --git

[2/2] kafka git commit: kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Post

2015-06-22 Thread junrao
kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Postava, Guozhang Wang and Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: