Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Commits on Nov 28, 2012
  1. @gmcdonald
Commits on Sep 27, 2012
  1. 0.7.2 Release Candidate 4

    Joe Stein authored
  2. KAFKA-533 changes to NOTICE and LICENSE related to KAFKA-534 removing…

    Joe Stein authored
    … client libraries from repo
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.2@1390789 13f79535-47bb-0310-9956-ffa450edef68
  3. KAFKA-534 remove client library directory

    Joe Stein authored
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.2@1390785 13f79535-47bb-0310-9956-ffa450edef68
Commits on Sep 19, 2012
  1. changed version number to match release

    Joe Stein authored
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.2@1387667 13f79535-47bb-0310-9956-ffa450edef68
  2. 0.7.2 Branch of latest trunk

    Joe Stein authored
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.2@1387661 13f79535-47bb-0310-9956-ffa450edef68
Commits on Sep 18, 2012
  1. TopicCount.constructTopicCount isn't thread-safe; patched by Jun Rao;…

    Jun Rao authored
    … reviewed by Joel Koshy; KAFKA-379
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1386987 13f79535-47bb-0310-9956-ffa450edef68
Commits on Sep 7, 2012
  1. Handle topic names with / on Kafka server; patched by Swapnil Ghike; …

    Jun Rao authored
    …reviewed by Jay Kreps and Jun Rao; kafka-495
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1381853 13f79535-47bb-0310-9956-ffa450edef68
Commits on Aug 29, 2012
  1. Message size not checked at the server (patch v3); patched by Swapnil…

    Jun Rao authored
    … Ghike; reviewed by Jun Rao; KAFKA-469
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1378590 13f79535-47bb-0310-9956-ffa450edef68
Commits on Aug 25, 2012
  1. Require values in Utils.getTopic* methods to be positive; patched by …

    Jun Rao authored
    …Swapnil Ghike; reviewed by Jun Rao; KAFKA-481
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1377213 13f79535-47bb-0310-9956-ffa450edef68
  2. Expose JMX operation to set logger level dynamically; patched by Jun …

    Jun Rao authored
    …Rao; reviewed by Jay Kreps; KAFKA-429
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1377172 13f79535-47bb-0310-9956-ffa450edef68
Commits on Aug 24, 2012
  1. Time based log segment rollout; patched by Swapnil Ghike; reviewed by…

    Jun Rao authored
    … Jun Rao, Neha Narkhede; KAFKA-475
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1377093 13f79535-47bb-0310-9956-ffa450edef68
  2. message size not checked at the server; patched by Swapnil Ghike; rev…

    Jun Rao authored
    …iewed by Jun Rao, Neha Narkhede; KAFKA-469
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1376943 13f79535-47bb-0310-9956-ffa450edef68
Commits on Jul 6, 2012
  1. KAFKA-373 Fix trunk broker failure test to work with mirror maker; pa…

    Joel Jacob Koshy authored
    …tched by John Fung; reviewed by Joel Koshy
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1358407 13f79535-47bb-0310-9956-ffa450edef68
Commits on Jun 20, 2012
  1. KAFKA-368 use the pig core jar from maven instead of distributing it …

    Joe Stein authored
    …patch by Joe Stein reviewed by Jun Rao and Neha Narkhede
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1352145 13f79535-47bb-0310-9956-ffa450edef68
Commits on Jun 19, 2012
  1. add jmx beans in broker to track # bytes in consumer; patched by Jun …

    Jun Rao authored
    …Rao; reviewed by Joel Koshy; KAFKA-336
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1351544 13f79535-47bb-0310-9956-ffa450edef68
Commits on Jun 14, 2012
  1. KAFKA-365 change copyright in NOTICE to current year, reviewed by Jun…

    Joe Stein authored
    … Rao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1350349 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
Something went wrong with that request. Please try again.