Kafka - Transaction

Table of Contents

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.

Powered by ComboStrap