...

public class TransactionStateCorruptedException extends ApiException {

    public TransactionStateCorruptedException(String message, Throwable cause) {
        super(msg, cause);
    }
}

Proposed Changes

Below is a full list of exception types that could be thrown from producer API as of today

1. ProducerFencedException
2. InvalidProducerEpochException
3. KafkaException, which potentially wraps the following exceptions:
   1. IllegalStateException
   2. InvalidPidMappingException
   3. TransactionAbortedException
   4. ClusterAuthorizationException
   5. TransactionalIdAuthorizationException
   6. UnsupportedVersionException
   7. KafkaException which indicates retriable idempotent sequence
   8. KafkaException which indicates fatal transactional sequence

Compatibility, Deprecation, and Migration Plan

...