Hi everybody, There is a new KIP regarding the resilience of GlobalStreamThread which could be seen below: https://cwiki.apache.org/confluence/display/KAFKA/KIP-406%3A+GlobalStreamThread+should+honor+custom+reset+policy
We are considering the new addition of some new reset policy. It would be great if you could pitch in! Thanks, Richard Yu