Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Commits on Sep 5, 2011
  1. @jkreps
Commits on Aug 1, 2011
  1. @nehanarkhede
Commits on Jul 30, 2011
  1. @nehanarkhede
  2. @nehanarkhede
  3. @nehanarkhede
Commits on Jul 29, 2011
  1. @nehanarkhede
  2. @nehanarkhede

    Renamed MessageOffset to MessageAndOffset. Cleaned up code. Changed m…

    nehanarkhede authored
    …ethod names to camel case in Message.scala. Moved compression config to ProducerConfig
  3. Adding a constructor with no compression parameter

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

    authored
    Fix a BufferUnderflowException in the StringDecoder
  2. @bmatheny
  3. @junrao

    Merge pull request #37 from bmatheny/patch-1

    junrao authored
    Spelling fix in log message.
Commits on Jul 26, 2011
  1. @bmatheny

    Spelling fix in log message.

    bmatheny authored
Commits on Jul 22, 2011
  1. @nehanarkhede

    More code cleanup. Changed the visibility of variables in ByteBufferM…

    nehanarkhede authored
    …essageSet to private with accessor methods. Deleted unused code
  2. @nehanarkhede

    Added backwards compatibility unit test to verify if older versions o…

    nehanarkhede authored
    …f magic byte can be understood by newer versions
  3. @nehanarkhede

    Handling IO Exceptions while compressing (producer side) or decompres…

    nehanarkhede authored
    …sing (consumer side) and rethrowing to the client
  4. @nehanarkhede

    Code cleanup. Deleted a constructor from ByteBufferMessageSet and an …

    nehanarkhede authored
    …overloaded method from MessageSet
  5. @nehanarkhede

    Added a system test for producer with compression enabled. Corrected …

    nehanarkhede authored
    …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. @nehanarkhede

    Corrected ByteBufferMessageSet to take in an initial offset and use t…

    nehanarkhede authored
    …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 authored
    … time for uncompressed messages and one compressed message at a time for compressed messages
Commits on Jul 20, 2011
  1. Merge branch 'master' of github.com:kafka-dev/kafka

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

    Neha Narkhede authored
    …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 authored
  2. Named arguments in unit tests and elsewhere. Represented compression …

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

    Neha Narkhede authored
    …s variables to immutable vals
  2. close socket during consumer reconnet

    Jun Rao authored
  3. More renaming of constants to conform to Scala style. Adding accessor…

    Neha Narkhede authored
    … 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 authored
    …r capital camel case
Commits on Jul 15, 2011
  1. @jghoman
Commits on Jul 7, 2011
  1. @javasoze
Something went wrong with that request. Please try again.