Kafka Transactional Producer

Hi,

Does Kafka Alpakka supports out of the box transactional producer, I mean like transaction on Producer part only where transactions are committed such as this

producer.initTransactions();
try {
producer.beginTransaction();
producer.send(record1);
producer.send(record2);
producer.commitTransaction();
} catch(ProducerFencedException e) {
producer.close();
} catch(KafkaException e) {
producer.abortTransaction();
}

or I should be the one to explicitly putting this

Hi @cheatmenot,

No, Alpakka Kafka does only support transactions in a consume-transform-produce workflow.
To achieve this you need to use the Kafka producer API directly.

Cheers,
Enno.