If this is a bug report, please fill out the following:
- Version of Ruby:
- Version of Kafka:
- Version of ruby-kafka:
Please verify that the problem you're seeing hasn't been fixed by the current master
of ruby-kafka.
kafka = Kafka.new(...)
# Please write an example that reproduces the problem you're describing.
What you thought would happen when running the example.
What actually happened.