mjsax opened a new pull request #9800: URL: https://github.com/apache/kafka/pull/9800
If EOS is enabled and the TX commit fails with a timeout, we should not process more messages (what is ok for non-EOS) because we don't really know the status of the TX. If the commit was indeed successful, we won't have an open TX and calling send() would fail with anfatal error. Instead, we should retry the (idempotent) commit of the TX, and start a new TX afterwards. Call for review @vvcephei @abbccdda @guozhangwang @hachikuji @bob-barrett ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
