ruby-kafka

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

Ruby

A Ruby client library for Apache Kafka

Kafka::OffsetManager#commit_offsets

Commit offsets of messages that have been marked as processed.

If `recommit` is set to true, we will also commit the existing positions
even if no messages have been processed on a partition. This is done
in order to avoid the offset information expiring in cases where messages
are very rare -- it's essentially a keep-alive.

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-commit_offsets-for-pr

# Commit to git

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

# 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-commit_offsets-for-pr

hub pull-request

# Celebrate!