Adrian Bordinc
Adrian Bordinc
The [Compressor](https://github.com/zendesk/ruby-kafka/blob/d3796daf8433611043f6680412b27355317896e1/lib/kafka/compressor.rb#L78-L81) class is pushing ActiveSupport notifications with metrics regarding the messages getting compressed. However these don't get pushed to StatsD/Datadog, since there's no subscriber for them. This PR adds...
We've recently seen a few errors in production. The error we see is `Broker: Not coordinator for group`. After this error gets thrown by our consumers, they... never recover and...
```sh $ keybase pgp gen ▶ INFO Generating primary key (4096 bits) ▶ INFO Generating encryption subkey (4096 bits) ▶ ERROR Operation timed out ``` my log id: d2e8f46271d74e8375ca8a1c