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.