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

    gmcdonald committed Nov 28, 2012
Commits on Jun 14, 2012
  1. Release Candidate 2 Tag

    Joe Stein committed Jun 14, 2012
  2. 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
  3. 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
Commits on Feb 15, 2012
  1. trivial fix to add trace logging in FetcherRunnable

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1244792 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 15, 2012
  2. fix condition to use await instead of wait; patched by Jun Rao; revie…

    …wed by Neha Narkhede; KAFKA-265
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1244765 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Feb 15, 2012
  3. add JMX on broker to track bytes/messages per topic; patched by Jun R…

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