Table of Contents
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.