We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Maybe I'm doing something wrong; or maybe there is an issue?
$ ruby -v ruby 2.5.1p57 (2018-03-29 revision 63029) [x86_64-linux]
$ bin/kafka-configs.sh --version 2.4.1 (Commit:c57222ae8cd7866b)
$ gem list | grep kafka ruby-kafka (1.5.0)
Please verify that the problem you're seeing hasn't been fixed by the current master of ruby-kafka.
master
1.4.0
Using the example at https://github.com/zendesk/ruby-kafka#consumer-groups, I see consumer.each_message(..) grab existing messages from the topic, then it just hangs.
consumer.each_message(..)
I had the same kinda of issue when getting messages via kafka.each_message(...)
kafka.each_message(...)
The consumer should continuously receive messages.
The consumer receives existing messages then stops receiving new messages.
See also
Ruby/lab4/solutions/lib/kafka_example.rb
The text was updated successfully, but these errors were encountered:
Issue has been marked as stale due to a lack of activity.
Sorry, something went wrong.
No branches or pull requests
Maybe I'm doing something wrong; or maybe there is an issue?
Please verify that the problem you're seeing hasn't been fixed by the current
master
of ruby-kafka.1.4.0
. Is there a regression in the master branch (which is showing v 1.5.0) that caused this issue?Steps to reproduce
Using the example at https://github.com/zendesk/ruby-kafka#consumer-groups, I see
consumer.each_message(..)
grab existing messages from the topic, then it just hangs.I had the same kinda of issue when getting messages via
kafka.each_message(...)
Expected outcome
The consumer should continuously receive messages.
Actual outcome
The consumer receives existing messages then stops receiving new messages.
See also
Ruby/lab4/solutions/lib/kafka_example.rb
The text was updated successfully, but these errors were encountered: