ruby-kafka

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

Ruby

A Ruby client library for Apache Kafka

Kafka::Broker#fetch_messages_async

Fetches messages asynchronously.

The fetch request is sent to the broker, but the response is not read.
This allows the broker to process the request, wait for new messages,
and send a response without the client having to wait. In order to
read the response, call `#call` on the returned object. This will
block the caller until the response is available.

Source | Google | Stack overflow

Edit

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

cd ruby-kafka

open lib/kafka/broker.rb

Contribute

# Make a new branch

git checkout -b -your-name--update-docs-Kafka--Broker-fetch_messages_async-for-pr

# Commit to git

git add lib/kafka/broker.rbgit commit -m "better docs for Kafka::Broker#fetch_messages_async"

# 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--Broker-fetch_messages_async-for-pr

hub pull-request

# Celebrate!