openAtomicProducer

abstract fun openAtomicProducer(transactionalId: String): Log.AtomicProducer<M>

Parameters

transactionalId

uniquely identifies this producer for Kafka's transaction coordinator. Must be stable across restarts for transaction recovery.