rdkafka-ruby

rdkafka-ruby copied to clipboard

Issue #168/string keys for consumer message headers

4

Addresses issue #168: - Change `Headers` to return `Hash` as documented, starting with corresponding spec change. - Rdoc updates. These simplifications are also included: - Change `Headers` to a `Module`...

ColinDKelley

No need to do it, this is for me to implement. ref https://github.com/edenhill/librdkafka/releases/tag/v1.6.0

mensfeld

Headers.from_native rdoc says it returns Hash<String, String> but actually it is Hash<Symbol, String>

5

I was surprised to get `headers` returned as a `Hash` when the [Headers documentation](https://github.com/appsignal/rdkafka-ruby/blob/main/lib/rdkafka/consumer/headers.rb#L7) and [Message documentation](https://github.com/appsignal/rdkafka-ruby/blob/main/lib/rdkafka/consumer/message.rb#L29) both say `Hash`. I'd happy to make a PR to address this. My...

ColinDKelley

Install fails on windows for all versions

7

I'm trying to install the gem on windows with: gem install rdkafka -v '0.8.1' (I tried all newer versions as well) But it fails with the following: PS C:\code> gem...

benmollet

Reference to Opaque is not released when Admin, Consumer or Producer is closed

4

Hello, I have observed that when a long-lived process such as sidekiq repeatedly creates and destroys Producers, the memory usage of the process increases. Apparently, the references from `Rdkafka::Config.opaques` seems...

wanabe

Use RUBYARCHDIR for library location if present

1

WIP previous revert: https://github.com/appsignal/rdkafka-ruby/pull/193

leonmaia

Using `partition_key` raises `Local: Timed out` errors

10

We've recently started using `partition_key` when producing messages and started seeing a big number of `Rdkafka::RdkafkaError: Local: Timed out (timed_out)` even with a small number of messages. IDK if this...

Draiken

Feature request: extend Rdkafka::Error with instance name

2

(I am willing to implement it) It would be good to have instance name (rd_kafka_name) in the error for debug purposes. Now we get an error message but there is...

mensfeld

When producing messages, this doc specifies that both keys and values should be string: https://github.com/appsignal/rdkafka-ruby/blob/b7c790b21427ad419d8144d6c56b0655e2148adc/lib/rdkafka/producer.rb#L81 but when received, they (headers) are casted to symbols: https://github.com/appsignal/rdkafka-ruby/blob/b7c790b21427ad419d8144d6c56b0655e2148adc/lib/rdkafka/consumer/headers.rb#L54 This creates inconsistency of expectations...

mensfeld

Installing rdkafka-ruby behind a proxy

21

Hi, I tried to install the gem with both `bundle install` using gemfile and `gem install rdkafka` but i'm behind a proxy and both fails. I suppose it has something...

shika-n