Class KafkaCommonMessagingAutoConfiguration.SpringKafkaRetryDisablingConfiguration

  • Enclosing class:
    KafkaCommonMessagingAutoConfiguration

    @Configuration
    public static class KafkaCommonMessagingAutoConfiguration.SpringKafkaRetryDisablingConfiguration
    extends Object
    Configuration that disables Spring Kafka retries.

    Spring Kafka provides a retry mechanism that works by seeking to the current offset when an exception occurs. By default, this happens 10 times before the message is skipped. This configuration disables that retry by configuring the back off attempts as 0.

    The intent is to allow the out of box Spring Integration retry be the sole retry mechanism.

    • Constructor Detail

      • SpringKafkaRetryDisablingConfiguration

        public SpringKafkaRetryDisablingConfiguration()