ruby-kafka
ruby-kafka copied to clipboard
zendesk
A Ruby client library for Apache Kafka
* Version of Ruby: 3.0 * Version of Kafka: not relevant (there are several) * Version of ruby-kafka: 1.5.0 I'm not sure how to set up an isolated example -...
This PR updates `.circleci/config.yml` to use CircleCI matrix jobs. It can make it easy to test with multiple Ruby and Kafka versions, and also can simplify duplicate statements. Here are...
* Version of Ruby: ruby 3.0.2p107 (2021-07-07 revision 0db68f0233) [x86_64-darwin20] * Version of Kafka: 6.1.1-ccs (Commit:c209f70c6c2e52ae) * Version of ruby-kafka: 1.4.0 (555281eb407c9fc7aa08e7ebedc950959ad4ac5f) ###### Steps to reproduce ```ruby require 'logger' require...
adds [kafka 2.8.0](https://downloads.apache.org/kafka/2.8.0/RELEASE_NOTES.html) to [3.1.1](https://downloads.apache.org/kafka/3.1.1/RELEASE_NOTES.html) to the CI tests
If this is a bug report, please fill out the following: * Version of Ruby: 3.1.0 * Version of Kafka: 1.1.1 * Version of ruby-kafka: 1.4.0 Please verify that the...
I was trying to find method similar to [offsetsForTimes](https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#offsetsForTimes(java.util.Map)) in java or [offsets_for_times](https://github.com/dpkp/kafka-python/blob/55ded554f9f5b470eeb53500e455ecd87f4d8f87/kafka/consumer/group.py#L864) in python. It was introduced to Kafka in [KAFKA-4148](https://github.com/apache/kafka/commit/eaaa433f). It is useful in writing on-demand/cron jobs to...
* Version of Ruby: 2.5.3 * Version of Kafka: 3.0 * Version of ruby-kafka: 1.4 After upgrading our Kafka version to 3.0, we started to get the following error from...
Kafka::AsyncProducer#produce has only one mechanism of propagating backpressure: raising Kafka::BufferOverflow. This is not a very good mechanism — it's more of a blow-up than build-up — but it does the...
I've added fetch_message_callback to each_message instance method of Consumer class. I think it might be useful for sending heartbeat events to other services.
Since OpenTelemetry is being widely adopted it makes sense to support exporting the metrics in OTel format. I'm not really sure how much work that it, but I'm willing to...
