Package org.springframework.kafka.retrytopic

Annotation Interface ExceptionBasedDltDestination

public @interface ExceptionBasedDltDestination
Annotation allowing to specify additional DLT which will be chosen when message processing caused the configured exception to be thrown.
Since:
3.2.0
Author:
Adrian Chlebosz

  • Required Element Summary

    Required Elements
    Modifier and Type
    Required Element
    Description
    Class<? extends Throwable>[]
    exceptions
    When message processing throws one of the exceptions configured here, then it should be eventually redirected to the DLT with name containing the extension configured through suffix().
    String
    suffix
    Suffix extension used when constructing the name for the new DLT.

  • Element Details

    • suffix

      String suffix
      Suffix extension used when constructing the name for the new DLT. It is placed before the main suffix configured through the $RetryableTopic.dltTopicSuffix(), so the final name is the product of these two.
      Returns:
      the configured suffix extension

    • exceptions

      Class<? extends Throwable>[] exceptions
      When message processing throws one of the exceptions configured here, then it should be eventually redirected to the DLT with name containing the extension configured through suffix(). The causes of the thrown exception will be traversed to match with any of configured ones.
      Returns:
      configured exceptions