Hello, We write up a KIP based on a straightforward mechanism implemented and tested in order to solve a practical issue in production. https://cwiki.apache.org/confluence/display/KAFKA/KIP-693%3A+Client-side+Circuit+Breaker+for+Partition+Write+Errors Look forward to hearing feedback and suggestions.
Thanks!