Permalink
Commits on Nov 29, 2012
  1. Fixing a comment

    committed Nov 29, 2012
  2. Refactoring a bit

    Adding config, documentation. Splitting out the HTTP-specific stuff
    (i.e., Jetty) from the Kafka stuff. Not really abstracting anything,
    just making it less tightly coupled
    committed Nov 29, 2012
Commits on Aug 24, 2012
  1. First pass at Kafka REST proxy

    committed Aug 24, 2012
Commits on Aug 17, 2012
  1. KafkaController NPE in SessionExpireListener; patched by Yang Ye; rev…

    …iewed by Jun Rao, Neha Narkhede; KAFKA-464
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1374467 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Aug 17, 2012
  2. enforce broker.id to be a non-negative integer; patched by Swapnil Gh…

    …ike; reviewed by Jun Rao, Neha Narkhede; KAFKA-424
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1374440 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Aug 17, 2012
Commits on Aug 16, 2012
  1. KAFKA-385 Fix race condition between checkSatisfied and expire in Req…

    …uestPurgatory; fixed constant expiration of follower fetch requests as checkSatisfied was not getting called; add metrics to the RequestPurgatory; add a KafkaTimer convenience class; patched by Joel Koshy; reviewed by Jun Rao and Jay Kreps.
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1374069 13f79535-47bb-0310-9956-ffa450edef68
    Joel Jacob Koshy committed Aug 16, 2012
Commits on Aug 15, 2012
  1. KafkaController.RequestSendThread can throw exception on broker socke…

    …t; patched by Yang Ye; reviewed by Jun Rao; KAFKA-459, KAFKA-460
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373448 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Aug 15, 2012
Commits on Aug 14, 2012
  1. KAFKA-323 Add more parameters to the log4j appender. Patch by Jose Qu…

    …inteiro.
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373067 13f79535-47bb-0310-9956-ffa450edef68
    Edward Jay Kreps committed Aug 14, 2012
  2. KAFKA-424. Fix command line usage description. Patch from Tommie.

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373056 13f79535-47bb-0310-9956-ffa450edef68
    Edward Jay Kreps committed Aug 14, 2012
  3. KAFKA-425 Wrong class name in scripts. Patch from Akira Kitada review…

    …ed by Jay Kreps.
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373054 13f79535-47bb-0310-9956-ffa450edef68
    Edward Jay Kreps committed Aug 14, 2012
  4. KAFKA-439 Fix bad javadoc. Patch from Jim Plush. Reviewed and modifie…

    …d by Jay Kreps.
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373052 13f79535-47bb-0310-9956-ffa450edef68
    Edward Jay Kreps committed Aug 14, 2012
  5. remove ZK dependency on producer; patched by Yang Ye; reviewed by Jun…

    … Rao; KAFKA-369
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1372724 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Aug 14, 2012
Commits on Aug 8, 2012
  1. Minor checkin to fix replication system test and jmx tool

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1370941 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Aug 8, 2012
Commits on Aug 6, 2012
  1. KAFKA-380 Enhance single_host_multi_brokers test with failure to trig…

    …ger leader re-election in replication; patched by John Fung; reviewed by Neha Narkhede, Jun Rao and Joel Koshy
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1369888 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Aug 6, 2012
Commits on Aug 1, 2012
  1. recommit: revisit the become leader and become follower state change …

    …operations using V3 design; patched by Yang Ye; reviewed by Neha Narkhede and Jun Rao; kafka-343
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1368092 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Aug 1, 2012
Commits on Jul 31, 2012
  1. KAFKA-384 Fix intermittent unit test failures and remove Thread.sleep…

    … statements; patched by Neha Narkhede; reviewed by Joel Koshy, Jun Rao and Jay Kreps
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1367821 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Jul 31, 2012
  2. revert commit to KAFKA-343 due to unit test failures

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1367811 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 31, 2012
  3. revisit the become leader and become follower state change operations…

    … using V3 design; patched by Yang Ye; reviewed by Neha Narkhede and Jun Rao; kafka-343
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1367619 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 31, 2012
Commits on Jul 27, 2012
  1. deal with empty TopicData list in producer and fetch request; patched…

    … by Jun Rao; reviewed by Neha Narkhede; KAFKA-412
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1366244 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 27, 2012
Commits on Jul 26, 2012
  1. NullPointerException in ConsumerFetcherManager; patched by Jun Rao; r…

    …eviewed by Neha Narkhede; KAFKA-418
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1366238 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 26, 2012
  2. single_host_multi_brokers system test fails on laptop; patched by Joh…

    …n Fung; reviewed by Jun Rao; kafka-413
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1366085 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 26, 2012
Commits on Jul 25, 2012
  1. KAFKA-405 Improve high watermark maintenance to store high watermarks…

    … for all partitions in a single .highwatermark file; patched by Neha Narkhede; reviewed by Jay Kreps and Jun Rao
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1365841 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Jul 25, 2012
Commits on Jul 24, 2012
  1. KAFKA-350 Enable message replication in the presence of failures; pat…

    …ched by Neha Narkhede; reviewed by Jun Rao and Jay Kreps
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1365199 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Jul 24, 2012
Commits on Jul 20, 2012
  1. Minor change: Deleting the doc for kafka.producer.Producer's construc…

    …tor. It is causing NoSuchElementException causing jenkins build to fail
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1364001 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Jul 20, 2012
Commits on Jul 19, 2012
  1. KAFKA-371 Refactoring of LogManager. Reviewed by Neha.

    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1363542 13f79535-47bb-0310-9956-ffa450edef68
    Edward Jay Kreps committed Jul 19, 2012
  2. KAFKA-352 Unknown topic error code handling for all requests; patched…

    … by Neha Narkhede; reviewed by Jay Kreps
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1363507 13f79535-47bb-0310-9956-ffa450edef68
    Neha Narkhede committed Jul 19, 2012
Commits on Jul 18, 2012
  1. KAFKA-371 Patch from Jonathan Creasy reviewed by me. Correctly handle…

    … the case of an empty string as topic name or invalid partition number.
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1363022 13f79535-47bb-0310-9956-ffa450edef68
    Edward Jay Kreps committed Jul 18, 2012
Commits on Jul 11, 2012
  1. ZookeeperConsumerConnector needs to connect to new leader after leade…

    …rship change; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-362
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1360261 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 11, 2012
Commits on Jul 10, 2012
  1. broker failure system test broken on replication branch; patched by J…

    …ohn Fung; reviewed by Joel Koshy and Jun Rao; KAFKA-306
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1359813 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 10, 2012
  2. broker failure system test broken on replication branch; patched by J…

    …ohn Fung; reviewed by Joel Koshy and Jun Rao; KAFKA-306
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1359812 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jul 10, 2012
Commits on Jun 29, 2012
  1. KAFKA-353 Tie producer-side ack with high watermark and progress of r…

    …eplicas; patched by Joel Koshy; reviewed by Jun Rao, Jay Kreps
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1355578 13f79535-47bb-0310-9956-ffa450edef68
    Joel Jacob Koshy committed Jun 29, 2012
Commits on Jun 26, 2012
  1. Consumer doesn't receive all data; patched by Jun Rao; reviewed by Jo…

    …hn Fung; KAFKA-372
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1354094 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jun 26, 2012
Commits on Jun 23, 2012
  1. using MultiFetch in the follower; patched by Jun Rao; reviewed by Joe…

    …l Koshy and Neha Narkhede; KAFKA-339
    
    git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1353086 13f79535-47bb-0310-9956-ffa450edef68
    Jun Rao committed Jun 23, 2012