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

    gmcdonald committed Nov 28, 2012
Commits on Sep 29, 2012
  1. 0.7.2 Release Candidate 5

    Joe Stein committed Sep 29, 2012
  2. KAFKA-538 missing apache license header in sbt and util.h

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.7.2@1391716 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Sep 29, 2012
Commits on Sep 27, 2012
  1. KAFKA-533 changes to NOTICE and LICENSE related to KAFKA-534 removing…

    … 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
    Joe Stein committed Sep 27, 2012
  2. KAFKA-534 remove client library directory

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

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

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

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

    …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
    Jun Rao committed Sep 7, 2012
Commits on Aug 29, 2012
  1. Message size not checked at the server (patch v3); patched by Swapnil…

    … 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
    Jun Rao committed Aug 29, 2012
Commits on Aug 25, 2012
  1. Require values in Utils.getTopic* methods to be positive; patched by …

    …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
    Jun Rao committed Aug 25, 2012
  2. Expose JMX operation to set logger level dynamically; patched by Jun …

    …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
    Jun Rao committed Aug 25, 2012
Commits on Aug 24, 2012
  1. Time based log segment rollout; patched by Swapnil Ghike; reviewed by…

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

    …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
    Jun Rao committed Aug 24, 2012
Commits on Jul 6, 2012
  1. KAFKA-373 Fix trunk broker failure test to work with mirror maker; pa…

    …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
    Joel Jacob Koshy committed Jul 6, 2012
Commits on Jun 20, 2012
  1. 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/trunk@1352145 13f79535-47bb-0310-9956-ffa450edef68
    Joe Stein committed Jun 20, 2012
Commits on Jun 19, 2012
  1. add jmx beans in broker to track # bytes in consumer; patched by Jun …

    …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
    Jun Rao 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/trunk@1350349 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