Permalink
Switch branches/tags
Nothing to show
Commits on Sep 22, 2012
  1. forgot to subtract current offset

    quipo committed Sep 22, 2012
Commits on Sep 16, 2012
  1. WS

    quipo committed Sep 16, 2012
  2. link to site

    quipo committed Sep 16, 2012
  3. - added support for GZIP compression (both in the producer and the co…

    quipo committed Sep 16, 2012
    …nsumer);
    
    - implemented stream-based iteration of messages (rather than loading the entire response in memory);
    - added base Kafka_Exception class (extending RuntimeException) and some child classes to catch specific errors;
    - added validation and error checking in several parts of the code (like CRC validation of messages, stream connection/EOF checks, response code verification);
    - added example producer for compressed messages;
    - completely refactored socket handling, to be more robust, with better error checking and handling of edge-cases;
    - added support for 64bit offsets;
    - better checks for responses from Kafka (fixed connection hanging);
    - added Zookeeper-based consumer, with support for multiple consumer groups, and for manual offset commit action (so it is possible to wait for an ACK from the message processor before advancing the offsets), and example code;
    - added support for OffsetRequest and getOffsetsBefore() in the SimpleConsumer class to query the state of the queue and recover consumption after old offsets become invalid because of expired data;
    - support for connection timeouts in microseconds;
    - vastly improved test suite.
Commits on Jul 1, 2011
  1. license + contact info

    quipo committed Jul 1, 2011
  2. First draft of C++ producer

    quipo committed Jul 1, 2011
Commits on Jun 29, 2011
  1. Upgrading producer send thread shutdown message to INFO. Adding a DEB…

    nehanarkhede committed Jun 29, 2011
    …UG log message for the last batch handled by the producer send thread before shutdown
  2. remove unnecessary import

    Jun Rao committed Jun 29, 2011
Commits on Jun 27, 2011
  1. Remove duplicate code between single and multi producer requests to m…

    cdegroot committed Jun 27, 2011
    …ake adding acks a bit easier (and general hygiene as well)
  2. Added "with IdeaProject" to most classes so "sbt idea" generates a be…

    cdegroot committed Jun 27, 2011
    …tter project structure.
Commits on Jun 21, 2011
  1. Bumping up the version to 0.6.1

    Neha Narkhede committed Jun 21, 2011
Commits on Jun 18, 2011
Commits on Jun 17, 2011
Commits on Jun 16, 2011
  1. Request level logging on the kafka server

    Neha Narkhede committed Jun 16, 2011
  2. Merge branch 'master' of github.com:kafka-dev/kafka

    Neha Narkhede committed Jun 16, 2011
Commits on Jun 1, 2011
  1. Adding a setup file for hadoop consumer to set write permissions on t…

    nehanarkhede committed Jun 1, 2011
    …he required hdfs directories
  2. Fixed producer perf script to calculate throughput correctly. Also fi…

    nehanarkhede committed Jun 1, 2011
    …xed the classpaths and configs for the hadoop consumer
Commits on May 24, 2011
  1. Changed README for java examples to reflect new scripts

    Neha Narkhede committed May 24, 2011
  2. Add scripts to run java examples

    Neha Narkhede committed May 24, 2011
Commits on May 23, 2011
  1. Descriptive messages in the shells

    Neha Narkhede committed May 23, 2011
  2. KAFKA-66: cleanup

    nehanarkhede committed May 23, 2011
  3. validate actual bytes written in MultiSetSend

    Jun Rao committed May 23, 2011
  4. add socket trace in MessageSetSend

    Jun Rao committed May 23, 2011
Commits on May 22, 2011
  1. catch all types of exceptions in SimpleConsumer

    Jun Rao committed May 22, 2011
Commits on May 19, 2011
Commits on May 18, 2011
  1. upgrade ZK to 3.3.3; KAFKA-65

    Jun Rao committed May 18, 2011
  2. fix consumer ERROR during close; KAFKA-64

    Jun Rao committed May 18, 2011