Kafka - Transaction

Note

• Calling commitTransaction() just publishes the TX commit marker to the topic so commited consumers know it's safe to consume the messages.
• There is only one transaction per producer possible. If you need different transactions for different threads you need a producer per thread.