Commits on Sep 12, 2012
  1. bumped version for bugfixes

    Alejandro Crosa committed Sep 12, 2012
  2. Merge branch 'ls/gemspec' of https://github.com/liamstewart/kafka-rb

    …into liamstewart-ls/gemspec
    Alejandro Crosa committed Sep 12, 2012
  3. Specs specified in s.test_files rather than s.files.

    Liam Stewart committed Sep 12, 2012
  4. Replace deprecated rubygems/gempackagetask with package_task.

    Don't specify rubygems_version - set when package created.
    Specify files in lib/spec with globs.
    Liam Stewart committed Sep 12, 2012
  5. bumped version

    Alejandro Crosa committed Sep 11, 2012
  6. added contributor

    Alejandro Crosa committed Sep 11, 2012
  7. bumping version for gem push

    Alejandro Crosa committed Sep 11, 2012
  8. @acrosa

    Merge pull request #12 from liamstewart/ls/multi_producer

    Multiproduce support
    acrosa committed Sep 11, 2012
Commits on Sep 11, 2012
  1. Remove code that now lives in the Encode module.

    Liam Stewart committed Sep 11, 2012
  2. Add a MultiProducer module.

    Like Producer, but doesn't have a fixed topic and partition. 'send' sends
    a single message or a set of messages to the same topic/partition using the
    'produce' request type. 'multi_send' sends groups of messages across
    partitions/topics using the 'multiproduce' request type.
    Liam Stewart committed Sep 11, 2012
  3. Add an Encoder module.

    Provides methods for encoding messages, produce requests, and multiproduce
    requests.
    Liam Stewart committed Sep 11, 2012
  4. Add a ProducerRequest class.

    A ProducerRequest instance is a very simple wrapper around a topic, partition,
    and set of messages.
    Liam Stewart committed Sep 11, 2012
  5. Make the default host/port constants in the IO module.

    Liam Stewart committed Sep 11, 2012
Commits on Aug 9, 2012
  1. @acrosa

    Merge pull request #11 from ept/compression

    Add consumer support for transparent gzip compression
    acrosa committed Aug 8, 2012
  2. @acrosa

    Merge pull request #10 from ept/spec-warning

    Fix a warning about top-level constant reference while running the specs
    acrosa committed Aug 8, 2012
  3. Add consumer support for transparent gzip compression

    The Scala Kafka producer implementation has support for gzip-compressing
    individual messages or sets of consecutive messages, and the compression
    is transparent to the Scala Kafka consumer implementation. It's very
    convenient (just a matter of setting compression.codec=1 in the producer
    config).
    
    The compression codec of a message is indicated in the bottom two bits
    of the 'attributes' byte of messages with magic == 1. This means it's
    possible to add transparent compression support to consumers without any
    configuration.
    
    This commit adds compression support to the Ruby consumer. Because a
    compressed message may actually contain more than one message inside it
    (this makes compression more effective by grouping lots of small
    messages into one big message), I had to move some of the parsing logic
    from Kafka::Consumer to Kafka::Message.
    committed Aug 8, 2012
Commits on Aug 8, 2012
  1. @acrosa

    Merge pull request #9 from ept/magic-version-1

    Support messages with magic version 1
    acrosa committed Aug 8, 2012
  2. Add support for magic byte == 1

    committed Aug 7, 2012
  3. Fix duplicated logic

    committed Aug 7, 2012
Commits on Jun 6, 2012
  1. @acrosa

    Merge pull request #7 from iconara/message_decode_optimization

    Optimized message decoding
    acrosa committed Jun 6, 2012
Commits on May 7, 2012
  1. @iconara

    Optimized message decoding

    One #unpack call, with a constant format specifier, yields about 50% speedup in message decoding.
    iconara committed May 7, 2012
Commits on Jan 14, 2012
  1. removing wooga specifics

    Ale committed Jan 14, 2012
  2. use canonical name for gem

    Ale committed Jan 14, 2012
  3. fixed my own name's spelling

    Ale committed Jan 14, 2012
Commits on Dec 12, 2011
  1. new version

    Stefan Mees committed Dec 12, 2011
Commits on Dec 7, 2011
  1. @tlossen

    edited README

    tlossen committed Dec 7, 2011
Commits on Dec 6, 2011
  1. @tlossen
Commits on Nov 4, 2011
  1. @tlossen

    fixed faulty spec

    tlossen committed Nov 4, 2011
  2. @tlossen

    ignore pkg folder

    tlossen committed Nov 4, 2011
  3. @tlossen
  4. fetch earliest offset when no offset is given

    Stefan Mees committed Nov 4, 2011
  5. fixed test errors with ruby 1.9.2

    Stefan Mees committed Nov 4, 2011