8000 Commits · erwink/kafka · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on Nov 26, 2012

copy branch 0.8 to trunk
Jun Rao
committed

Commits on Nov 19, 2012

move shutting down of fetcher thread out of critical path; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-612
Jun Rao
committed

Commits on Nov 18, 2012

KAFKA-532 Multiple controllers can co-exist during soft failures; patched by Neha Narkhede; reviewed by Jun Rao
Neha Narkhede
committed

Commits on Nov 17, 2012

Fix deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-618
Joel Jacob Koshy
committed
MigrationTool should disable shallow iteration in the 0.7 consumer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-613
Jun Rao
committed
DumpLogSegment offset verification is incorrect for compressed messages; patched by Yang Ye; reviewed by Jun Rao; KAFKA-614
Jun Rao
committed

Commits on Nov 16, 2012

Commits on Nov 15, 2012

KAFKA-545 Add some log performance tests.
Edward Jay Kreps
committed
KAFKA-544 Store the key given to the producer in the message. Expose this key in the consumer. Patch reviewed by Jun.
Edward Jay Kreps
committed
KAFKA-574 KafkaController unnecessarily reads leaderAndIsr info from ZK ; patched by Prashanth; reviewed by Jun and Neha
Neha Narkhede
committed

Commits on Nov 14, 2012

Remove custom metrics jar and replace with latest from metrics HEAD; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-585.
Joel Jacob Koshy
committed

Commits on Nov 9, 2012

Add test cases to test log size retention and more; patched by John Fung; reviewed by Jun Rao; KAFKA-591
Jun Rao
committed

Commits on Nov 8, 2012

Fix commit() in zk consumer for compressed messages; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-546
Jun Rao
committed

Commits on Nov 6, 2012

KAFKA-593 Empty log index file created when it shouldn't be empty; Patched by Yang Ye; reviewed by Jun and Jay
Neha Narkhede
committed

Commits on Nov 5, 2012

Commits on Nov 2, 2012

KAFKA-188 Support multiple data directories.
Edward Jay Kreps
committed
KafkaRequestHandler needs to handle exceptions; patched by Yang Ye; reviewed by Jun Rao; KAFKA-491
Jun Rao
committed

Commits on Oct 31, 2012

Commits on Oct 30, 2012

Commits on Oct 29, 2012

extend DumpLogSegments to verify consistency btw data and index; patched by Yang Ye; reviewed by Neha Narkhede and Jun Rao; KAFKA-577
Jun Rao
committed

Commits on Oct 27, 2012

trivial fix to use foreach instead of map
Jun Rao
committed

Commits on Oct 26, 2012

Implement clean shutdown in replication; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-340
Joel Jacob Koshy
committed

Commits on Oct 25, 2012

produce/fetch remote time metric not set correctly when num.acks = 1; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-584
Jun Rao
committed

Commits on Oct 24, 2012

0