Need transaction support to group batch of records in message publisher - ReactiveMessaging/KafkaConnector

[santhoshpt]

Environment Details

• Helidon Version: 2.4.2
• Helidon MP
• JDK version: 11.0.13
• OS: Windows 10
• Docker version (if applicable):

---

Problem Description

• "In Helidon Message, we don't have the transaction support to batch bunch of messages for publishing. So that the consumer can read with read_comitted isolation level"
• "As a producer I need to batch bunch of messages are single transaction, in apache-kafka it can be done using commitTransaction()"

Sample code of apache kafka client

KafkaProducer<String, String> producer = new KafkaProducer<>(configProps);
producer.initTransactions();
producer.beginTransaction();
ProducerRecord<String, String> record;
try {
	long timeInMillies = System.currentTimeMillis();
	for (int i = 1; i <= 10; i++) {
		record = new ProducerRecord<>(topic, "Hai_" + timeInMillies + "_" + i);
		producer.send(record);
		log.info("Sending the message --> " + record.value());
		Thread.sleep(1000);
	}
	log.info("Commiting the transaction");
	producer.commitTransaction();
} catch (KafkaException kafkaExec) {
	producer.abortTransaction();
	kafkaExec.printStackTrace();
}
producer.close();