Spring Cloud Stream против Kafka Stream для функции "Точно однажды"

Spring Cloud Stream не делает ничего конкретного в отношении гарантий обработки. Вы можете делегировать это в Kafka Streams, предоставив свойство processing.guarantee и установив его в exactly-once. Смотрите этот для более подробной информации. При использовании связывателя Spring Cloud Stream Kafka Streams вы можете указать это как свойство для приложения Spring Boot, как показано ниже.

spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee.

Имейте в виду, что гарантия Kafka Stream ровно один раз работает, только если вы отправляете результаты обратно в Kafka.