Permalink
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…

    …ethod names to camel case in Message.scala. Moved compression config to ProducerConfig
    nehanarkhede committed Jul 29, 2011
  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

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

    Spelling fix in log message.
    junrao committed Jul 27, 2011
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…

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

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

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

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

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

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

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

    Conflicts:
    	core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
    Neha Narkhede committed Jul 20, 2011
  2. Changing the MessageSet to return an iterator over (message,offset) p…

    …airs where offset represents offset to be used for the next message
    Neha Narkhede committed Jul 20, 2011
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 …

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

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

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

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

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