I am trying to use executeInTransaction to publish the messages into kafka in Spring kafka. But i am getting the following error.
Caused by: org.apache.kafka.common.errors.TransactionalIdAuthorizationException: Transactional Id authorization failed.
I have set the transaction id prefix to producer factory.
kafkaProducerFactory.setTransactionIdPrefix("my.reconTxn.");