Hello Boyang, Thank you for the proposed KIP. Just some minor comments below:
1. Could you also describe which producer APIs could potentially throw the new TransactionTimedOutException, and also how should callers handle them differently (i.e. just to make your description more concrete as javadocs). 2. It's straight-forward if client is on newer version while broker's on older version; however If the client is on older version while broker's on newer version, today would the internal module of producers treat it as a general fatal error or not? If not, should the broker set a different error code upon detecting older request versions? Guozhang On Thu, Apr 2, 2020 at 1:40 PM Boyang Chen <reluctanthero...@gmail.com> wrote: > Hey there, > > I would like to start discussion for KIP-588: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-588%3A+Allow+producers+to+recover+gracefully+from+transaction+timeouts > > which aims to improve Producer resilience to transaction timeout due to > transient system gaps. > > Best, > Boyang > -- -- Guozhang