Spring Cloud Stream со связывателем RabbitMQ, как применить @Transactional?

У меня есть приложение Весенний поток облаков, которое получает события от RabbitMQ, используя Связующий кролик. Мое приложение можно резюмировать следующим образом:

@Transactional
@StreamListener(MySink.SINK_NAME)
public void processEvents(Flux<Event> events) {
       // Transform events and store them in MongoDB using 
       // spring-boot-data-mongodb-reactive
       ...
}

Проблема в том, что не похоже, что @Transactional работает с Spring Cloud Stream (или, по крайней мере, это мое впечатление), поскольку, если есть исключение при записи в MongoDB, событие, похоже, уже было подтверждено: ed в RabbitMQ, а операция не повторил.

Учитывая, что я хочу достичь в основном той же функциональности, что и при использовании @Transactional вокруг функции с весна-amqp:

1. Должен ли я вручную подтверждать сообщения RabbitMQ при использовании Spring? Cloud Stream с Rabbit Binder?
2. Если да, то как я могу этого добиться?