Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Commits on Nov 28, 2012
  1. @gmcdonald
Commits on Jun 14, 2012
  1. Release Candidate 1 Tag

    Joe Stein authored
  2. created branch for the 0.7.1 release

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

    Neha Narkhede authored
    …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
Commits on Apr 25, 2012
  1. Mirroring should use multiple producers; add producer retries to Defa…

    Jun Rao authored
    …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
Commits on Apr 8, 2012
  1. KAFKA-320 testZKSendWithDeadBroker fails intermittently due to ZKNode…

    Neha Narkhede authored
    …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
Commits on Apr 7, 2012
  1. Separate out Kafka mirroring into a stand-alone app; patched by Joel …

    Jun Rao authored
    …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
Commits on Apr 6, 2012
  1. enable shallow iterator in ByteBufferMessageSet to allow mirroing dat…

    Jun Rao authored
    …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
  2. CallbackHandler.afterDequeuingExistingData is not called during event…

    Jun Rao authored
    … 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
Commits on Mar 22, 2012
  1. KAFKA-309 Bug in FileMessageSet's append API can corrupt on disk log;…

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

    Neha Narkhede authored
    …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
Commits on Mar 21, 2012
  1. Dead code in the Log4j appender; patched by Jose Quinteiro; reviewed …

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

    Jun Rao authored
    …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
Commits on Mar 15, 2012
  1. reverting previous commit for KAFKA-296 because patch didn't apply cl…

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

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

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

    Jun Rao authored
    …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
Commits on Mar 1, 2012
Commits on Feb 29, 2012
  1. use propertyExists to test if both broker.list and zk.connect are pre…

    Jun Rao authored
    …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
Commits on Feb 28, 2012
  1. Increase maximum value of log.retention.size; patched by Elben Shira;…

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

    Jun Rao authored
    …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
Commits on Feb 25, 2012
  1. add jmx beans in broker to track # of failed requests; patched by Jun…

    Jun Rao authored
    … 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
Commits on Feb 23, 2012
  1. Add a shallow iterator to the ByteBufferMessageSet; patched by Yang Y…

    Jun Rao authored
    …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
Commits on Feb 21, 2012
  1. A tool to UPDATE Zookeeper partition-offset with input from a file; p…

    Jun Rao authored
    …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
  2. A tool to GET Zookeeper partition-offset and output to files; patched…

    Jun Rao authored
    … 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
Commits on Feb 20, 2012
  1. make time-based reconnect starting at a random time; patched by Yang …

    Jun Rao authored
    …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
Commits on Feb 17, 2012
  1. trivial fix for kafka-producer-perf-test.sh

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

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

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

    Jun Rao authored
    … by Neha Narkhede; KAFKA-265
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1245295 13f79535-47bb-0310-9956-ffa450edef68
Commits on Feb 15, 2012
  1. trivial fix to add trace logging in FetcherRunnable

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

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

    Jun Rao authored
    …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
Commits on Feb 14, 2012
  1. time-based reconnect in producer; patched by Yang Ye; reviewed by Jun…

    Jun Rao authored
    … Rao; KAFKA-268
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1243786 13f79535-47bb-0310-9956-ffa450edef68
Something went wrong with that request. Please try again.