Permalink
Commits on Jan 29, 2016
  1. Merge pull request #28 from aviflax/patch-1

    Replace README contents with a OBSOLETE notice
    committed Jan 29, 2016
Commits on May 1, 2015
  1. Merge pull request #24 from terrancesnyder/master

    Updates to fix issue when reading snappy
    committed May 1, 2015
Commits on Apr 6, 2015
  1. update version #

    terrancesnyder committed Apr 6, 2015
  2. pre-install notes

    terrancesnyder committed Apr 6, 2015
  3. pre-install notes

    terrancesnyder committed Apr 6, 2015
  4. More real world example

    More real world example including reading AVRO from kafka
    terrancesnyder committed Apr 6, 2015
  5. Fix

    Not required with latest snappy lib - serializes just fine
    terrancesnyder committed Apr 6, 2015
  6. Not required anymore...

    terrancesnyder committed Apr 6, 2015
Commits on Mar 31, 2013
  1. bumped gemspec for bugfix

    Ale committed Mar 31, 2013
  2. changed ambiguous method send for push

    Ale committed Mar 31, 2013
  3. updated and bumped gemspec

    Ale committed Mar 31, 2013
  4. updated gemspec

    Ale committed Mar 31, 2013
  5. Merge pull request #20 from MichaelXavier/producer-send-rename

    Rename producer/multi-producer methods to push
    committed Mar 31, 2013
Commits on Mar 5, 2013
  1. Rename producer/multi-producer methods to push

    Send is problematic in ruby because it is defined on all objects as a
    way to dynamically send method calls (messages). You do not want to have
    any methods in your interface that define send.
    
    This would resolve #18
    MichaelXavier committed Mar 5, 2013
Commits on Feb 16, 2013
  1. Add kafka-subscribe and kafka-publish commands

    *kafka-subscribe* and *kafka-publish* are command line programs to help
    in the task of debugging a kafka installation.
    guillermo committed Feb 16, 2013
Commits on Dec 19, 2012
  1. Merge pull request #15 from bcotton/snappy-compression

    Added Snappy compression
    committed Dec 19, 2012
Commits on Dec 11, 2012
  1. Added support for Snappy compression to the Consumer, and added compr…

    …ession (Snappy and GZip) to the Producer and MultiProducer.
    
    To enable snappy compression, include the following in your Gemfile (This branch is necessary until a pending pull request is accepted):
    
        gem "snappy", "0.0.4", :git => "git://github.com/watersofoblivion/snappy.git", :branch => "snappy-streaming"
    Bob Cotton committed with watersofoblivion Sep 14, 2012
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 12, 2012
  6. added contributor

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

    Alejandro Crosa committed Sep 12, 2012
  8. Merge pull request #12 from liamstewart/ls/multi_producer

    Multiproduce support
    committed Sep 12, 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. Merge pull request #11 from ept/compression

    Add consumer support for transparent gzip compression
    committed Aug 9, 2012