Я пытаюсь использовать executeInTransaction для публикации сообщений в kafka в Spring kafka. Но я получаю следующую ошибку.
Caused by: org.apache.kafka.common.errors.TransactionalIdAuthorizationException: Transactional Id authorization failed.
Я установил префикс идентификатора транзакции для фабрики производителя.
kafkaProducerFactory.setTransactionIdPrefix("my.reconTxn.");