Он обрабатывается платформой автоматически, если вы добавляете KafkaTransactionManager
в контекст приложения.
Вам необходимо добавить префикс идентификатора транзакции в конфигурацию.
spring.kafka.producer.transaction-id-prefix
и Boot автоматически добавит менеджер транзакций.
См. Свойства производителя .
spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix
Включает транзакции всвязующее.См. Transaction.id в документации Kafka и Транзакции в документации spring-kafka.Когда транзакции включены, отдельные свойства производителя игнорируются, и все производители используют spring.cloud.stream.kafka.binder.transaction.producer. * Properties.
Контейнер слушателя отправляет смещение в транзакциюперед совершением транзакции, когда слушатель нормально выходит.