ruby-kafka

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

Ruby

A Ruby client library for Apache Kafka

Kafka::Producer#deliver_messages

Sends all buffered messages to the Kafka brokers.

Depending on the value of `required_acks` used when initializing the producer,
this call may block until the specified number of replicas have acknowledged
the writes. The `ack_timeout` setting places an upper bound on the amount of
time the call will block before failing.

Source | Google | Stack overflow

Edit

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

cd ruby-kafka

open lib/kafka/producer.rb

Contribute

# Make a new branch

git checkout -b -your-name--update-docs-Kafka--Producer-deliver_messages-for-pr

# Commit to git

git add lib/kafka/producer.rbgit commit -m "better docs for Kafka::Producer#deliver_messages"

# 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--Producer-deliver_messages-for-pr

hub pull-request

# Celebrate!