Commits on Sep 5, 2011
Commits on Aug 1, 2011
Commits on Jul 30, 2011
Commits on Jul 29, 2011
  1. Renamed MessageOffset to MessageAndOffset. Cleaned up code. Changed m…

    nehanarkhede committed Jul 29, 2011
    …ethod names to camel case in Message.scala. Moved compression config to ProducerConfig
  2. Adding a constructor with no compression parameter

    Neha Narkhede committed Jul 29, 2011
Commits on Jul 27, 2011
  1. Merge pull request #39 from bmatheny/master

    kafka-dev committed Jul 27, 2011
    Fix a BufferUnderflowException in the StringDecoder
  2. Merge pull request #37 from bmatheny/patch-1

    junrao committed Jul 27, 2011
    Spelling fix in log message.
Commits on Jul 26, 2011
  1. Spelling fix in log message.

    bmatheny committed Jul 26, 2011
Commits on Jul 22, 2011
  1. More code cleanup. Changed the visibility of variables in ByteBufferM…

    nehanarkhede committed Jul 22, 2011
    …essageSet to private with accessor methods. Deleted unused code
  2. Added backwards compatibility unit test to verify if older versions o…

    nehanarkhede committed Jul 22, 2011
    …f magic byte can be understood by newer versions
  3. Handling IO Exceptions while compressing (producer side) or decompres…

    nehanarkhede committed Jul 22, 2011
    …sing (consumer side) and rethrowing to the client
  4. Code cleanup. Deleted a constructor from ByteBufferMessageSet and an …

    nehanarkhede committed Jul 22, 2011
    …overloaded method from MessageSet
  5. Added a system test for producer with compression enabled. Corrected …

    nehanarkhede committed Jul 22, 2011
    …the logic for enforcing compressed.topics. Changed message.isValid to check the magic byte and throw UnknownMagicByteException if magic byte is unknown
Commits on Jul 21, 2011
  1. Corrected ByteBufferMessageSet to take in an initial offset and use t…

    nehanarkhede committed Jul 21, 2011
    …hat in the iterator to return the correct offset to consume the next message
  2. Consumer Iterator modified to update consumed offset one message at a…

    Neha Narkhede committed Jul 21, 2011
    … time for uncompressed messages and one compressed message at a time for compressed messages
Commits on Jul 20, 2011
  1. Merge branch 'master' of

    Neha Narkhede committed Jul 20, 2011
  2. Changing the MessageSet to return an iterator over (message,offset) p…

    Neha Narkhede committed Jul 20, 2011
    …airs where offset represents offset to be used for the next message
Commits on Jul 19, 2011
  1. Enforcing the compressed.topics config option

    Neha Narkhede committed Jul 19, 2011
  2. Named arguments in unit tests and elsewhere. Represented compression …

    Neha Narkhede committed Jul 19, 2011
    …codec using Case object
Commits on Jul 18, 2011
  1. ByteBufferMessageSet constructor refactored to be able to change clas…

    Neha Narkhede committed Jul 18, 2011
    …s variables to immutable vals
  2. close socket during consumer reconnet

    Jun Rao committed Jul 18, 2011
  3. More renaming of constants to conform to Scala style. Adding accessor…

    Neha Narkhede committed Jul 18, 2011
    … methods to ByteBufferMessageSet class variables and making them private
Commits on Jul 17, 2011
  1. Changing all constant names from C style to Scala style - First lette…

    Neha Narkhede committed Jul 17, 2011
    …r capital camel case
Commits on Jul 15, 2011
Commits on Jul 7, 2011