0

I've just read KIP-477 and review Merge Request, so my present understanding is there is no need to include group, topic and partition in transaction.id using Kafka 2.6.0+, as it is described here.

So is it safe to simply set transaction.id to UUID.randomUUID()? In case of unexpected application shutdown, waiting for a previous transaction timeout is ok for me.

Paweł Szymczyk
  • 1,638
  • 15
  • 20

0 Answers0