[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171051#comment-17171051 ]
John Thomas commented on KAFKA-10186: ------------------------------------- Thanks Sophie. I'll let Gokul work on it. [~nym3r0s] Feel free to pick it up. This would be a good place to start with : [https://kafka.apache.org/contributing] and since we would need a KIP for this, refer [https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals] > Aborting transaction with pending data should throw non-fatal exception > ----------------------------------------------------------------------- > > Key: KAFKA-10186 > URL: https://issues.apache.org/jira/browse/KAFKA-10186 > Project: Kafka > Issue Type: Improvement > Components: producer > Reporter: Sophie Blee-Goldman > Priority: Major > Labels: needs-kip, newbie, newbie++ > > Currently if you try to abort a transaction with any pending (non-flushed) > data, the send exception is set to > {code:java} > KafkaException("Failing batch since transaction was aborted"){code} > This exception type is generally considered fatal, but this is a valid state > to be in -- the point of throwing the exception is to alert that the records > will not be sent, not that you are in an unrecoverable error state. > We should throw a different (possibly new) type of exception here to > distinguish from fatal and recoverable errors. -- This message was sent by Atlassian Jira (v8.3.4#803005)