Yegor Myskin

It would be nice to place some kind of an interceptor to handle metrics manually. Maybe this method could live inside the `Policy`. Something like: ``` // RPCStats is a...

IP validation failed ``` if net.ParseIP(ipAddr).To4() == nil { continue } ``` Workers loop failed: ``` func runWorker(ctx context.Context) { for { if ctx.Err() != nil { return } //...

https://github.com/Shopify/sarama/issues/760 maybe related to this

The same, no rebalances, just errors `kafka server: Request exceeded the user-specified time limit in the request. `