ruby-kafka

https://github.com/zendesk/ruby-kafka

Ruby

A Ruby client library for Apache Kafka

Kafka::OffsetManager#set_default_offset

Set the default offset for a topic.

When the consumer is started for the first time, or in cases where it gets stuck and
has to reset its position, it must start either with the earliest messages or with
the latest, skipping to the very end of each partition.

Source | Google | Stack overflow

Edit

git clone [email protected]:zendesk/ruby-kafka.git

cd ruby-kafka

open lib/kafka/offset_manager.rb

Contribute

# Make a new branch

git checkout -b -your-name--update-docs-Kafka--OffsetManager-set_default_offset-for-pr

# Commit to git

git add lib/kafka/offset_manager.rbgit commit -m "better docs for Kafka::OffsetManager#set_default_offset"

# Open pull request

gem install hub # on a mac you can `brew install hub`

hub fork

git push <your name> -your-name--update-docs-Kafka--OffsetManager-set_default_offset-for-pr

hub pull-request

# Celebrate!