Dan Markhasin
Dan Markhasin
+1 We really like this library, but this is a deal breaker for us - if our services are failing to produce to Kafka, we MUST know about it. Confluent's...
They simply don't align with our existing logging and metrics infrastructure. For example, we use https://github.com/rcrowley/go-metrics - I don't really see how `WriterStats` would integrate with it, whereas in an...
I took a stab at a naive implementation via #420
Mostly metrics in our case, which serve as the basis for monitors and alerts. A high rate of async produce failures should start ringing bells, but we shouldn't be sacrificing...
You need to use the consumergroup API. See an example here: https://github.com/segmentio/kafka-go/blob/master/example_consumergroup_test.go
We are doing exactly that just now - splitting the interface :) It has some drawbacks for us though, since using a single interface would have allowed us to clean...
As a user, having Feign only proxy annotated methods makes more sense and addresses the issue in this request and in #615.
Can you release it..?
AFAIK this is a long standing issue in the Kafka ecosystem (in all client languages). I would suggest that instead of coding the rotation logic in the library, it should...
There doesn't seem to be any solution for this, except for using Ruby filter directly.