acrosa / kafka-rb

A simple Producer/Consumer client for Kafka (a distributed publish/subscribe messaging service)
Apache License 2.0
171 stars 43 forks source link

Added the possiblity to fetch the earliest available offset #21

Open leffen opened 11 years ago

leffen commented 11 years ago

Needed the possiblity to restart reading from the start of the que, and when the start offset is not zero then i just returns an empty set. So it needs to be initialized with the first available offset. A bit unsure how to write a good test for it thou.