InvalidTxnStateException

Kafka InvalidTxnStateException: Causes and How to Fix It

InvalidTxnStateException means your producer called a transactional API in the wrong state. Here's the state machine, the exact triggers, and the fix.