Permalink
Commits on Nov 28, 2012
  1. Kafka has become a TLP

    gmcdonald committed Nov 28, 2012
Commits on Jun 20, 2012
  1. tag for 0.7.1 release candidate 3

    Joe Stein committed Jun 20, 2012
  2. KAFKA-368 use the pig core jar from maven instead of distributing it …

    …patch by Joe Stein reviewed by Jun Rao and Neha Narkhede
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.1@1352144 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Jun 20, 2012
Commits on Jun 19, 2012
  1. project version of branch should be 0.7.1 oversight in missing this c…

    …hange when first branching for this release
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.1@1351573 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Jun 19, 2012
  2. KAFKA-366 add jmx beans in broker to track # bytes in consumer patch …

    …by Jun Rao reviewed by Joel Koshy merged into the 0.7.1 release
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.1@1351572 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Jun 19, 2012
Commits on Jun 14, 2012
  1. KAFKA-365 change copyright in NOTICE to current year, reviewed by Jun…

    … Rao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.1@1350349 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Jun 14, 2012
  2. created branch for the 0.7.1 release

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.1@1350089 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Jun 14, 2012
Commits on May 18, 2012
  1. Minor fix: Turning on TCP NODELAY in the Simple Consumer. This fix ha…

    …s a significant impact on single fetch request performance from a latency standpoint
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1339944 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed May 18, 2012
Commits on Apr 25, 2012
  1. Mirroring should use multiple producers; add producer retries to Defa…

    …ultEventHandler; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-332
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1330083 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Apr 25, 2012
Commits on Apr 8, 2012
  1. KAFKA-320 testZKSendWithDeadBroker fails intermittently due to ZKNode…

    …ExistsException; patched by nehanarkhede; reviewed by junrao and prashanth menon
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1310937 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Apr 8, 2012
Commits on Apr 7, 2012
  1. Separate out Kafka mirroring into a stand-alone app; patched by Joel …

    …Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-249
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1310645 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Apr 7, 2012
Commits on Apr 6, 2012
  1. enable shallow iterator in ByteBufferMessageSet to allow mirroing dat…

    …a without decompression; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-315
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1310595 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Apr 6, 2012
  2. CallbackHandler.afterDequeuingExistingData is not called during event…

    … queue timeout; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-326
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1310482 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Apr 6, 2012
Commits on Mar 22, 2012
  1. KAFKA-309 Bug in FileMessageSet's append API can corrupt on disk log;…

    … patched by nehanarkhede; reviewed by junrao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1303890 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Mar 22, 2012
  2. KAFKA-310 Incomplete message set validation checks in Log's append AP…

    …I can corrupt on disk log segment; patched by nehanarkhede; reviewed by junrao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1303861 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Mar 22, 2012
Commits on Mar 21, 2012
  1. Dead code in the Log4j appender; patched by Jose Quinteiro; reviewed …

    …by Jun Rao; KAFKA-303
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1303239 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 21, 2012
  2. kafka-console-producer does not take in customized values of --batch-…

    …size or --timeout; patched by Jun Rao; reviewed by Edward Smith; KAFKA-279
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1303232 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 21, 2012
Commits on Mar 15, 2012
  1. reverting previous commit for KAFKA-296 because patch didn't apply cl…

    …eanly
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1300801 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 15, 2012
Commits on Mar 14, 2012
  1. Update Go Client to new version of Go; patched by AaronR; KAFKA-296

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1300777 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 14, 2012
Commits on Mar 8, 2012
  1. LogManager test fails on linux; patched by Jun Rao; reviewed by Neha …

    …Narkhede; KAFKA-220
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1298426 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 8, 2012
Commits on Mar 7, 2012
  1. trivial fix to include violated payload size in MessageSizeTooLargeEx…

    …ception; patched by Jun Rao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1298030 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 7, 2012
Commits on Mar 6, 2012
  1. broker deletes all file segments when cleaning up an empty log segmen…

    …t; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-292
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1297324 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Mar 6, 2012
Commits on Mar 1, 2012
  1. Niek Sanders - KAFKA-284 fixed compilation issue for cpp client

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1295388 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Mar 1, 2012
Commits on Feb 29, 2012
  1. use propertyExists to test if both broker.list and zk.connect are pre…

    …sent; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-290
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1294959 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 29, 2012
Commits on Feb 28, 2012
  1. Increase maximum value of log.retention.size; patched by Elben Shira;…

    … reviewed by Jun Rao; KAFKA-285
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1294441 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 28, 2012
Commits on Feb 27, 2012
  1. consumer sometimes don't release partition ownership properly in ZK d…

    …uring rebalance; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-286
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1294302 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 27, 2012
Commits on Feb 25, 2012
  1. add jmx beans in broker to track # of failed requests; patched by Jun…

    … Rao; reviewed by Neha Narkhede; KAFKA-283
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1293720 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 25, 2012
Commits on Feb 23, 2012
  1. Add a shallow iterator to the ByteBufferMessageSet; patched by Yang Y…

    …e; reviewed by Jun Rao; KAFKA-277
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1293010 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 23, 2012
Commits on Feb 21, 2012
  1. A tool to UPDATE Zookeeper partition-offset with input from a file; p…

    …atched by John Fung; reviewed by Jun Rao; KAFKA-255
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1291536 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 21, 2012
  2. A tool to GET Zookeeper partition-offset and output to files; patched…

    … by John Fung; reviewed by Jun Rao; KAFKA-254
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1291535 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 21, 2012
Commits on Feb 20, 2012
  1. make time-based reconnect starting at a random time; patched by Yang …

    …Ye; reviewed by Jun Rao; KAFKA-268
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1291490 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 20, 2012
Commits on Feb 17, 2012
  1. trivial fix for kafka-producer-perf-test.sh

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1245779 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 17, 2012
  2. test access, fixed space

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1245316 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Feb 17, 2012
  3. KAFKA-274 Handle corrupted messages cleanly; patched by nehanarkhede;…

    … reviewed by junrao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1245299 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Feb 17, 2012
  4. shutdown watch executor thread properly; patched by Jun Rao; reviewed…

    … by Neha Narkhede; KAFKA-265
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1245295 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 17, 2012