Package org.flowable.eventregistry.spring.kafka

Class KafkaChannelDefinitionProcessor.ResolvedRetryConfiguration

java.lang.Object
org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor.ResolvedRetryConfiguration
Enclosing class:
KafkaChannelDefinitionProcessor
protected static class KafkaChannelDefinitionProcessor.ResolvedRetryConfiguration extends Object

  • Field Details

    • attempts

      protected Integer attempts

    • dltTopicSuffix

      protected String dltTopicSuffix

    • retryTopicSuffix

      protected String retryTopicSuffix

    • sameIntervalTopicReuseStrategy

      protected SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy

    • topicSuffixingStrategy

      protected TopicSuffixingStrategy topicSuffixingStrategy

    • nonBlockingBackOff

      protected org.springframework.retry.backoff.SleepingBackOffPolicy<?> nonBlockingBackOff

    • autoCreateTopics

      protected boolean autoCreateTopics

    • numPartitions

      protected int numPartitions

    • replicationFactor

      protected short replicationFactor

  • Constructor Details

    • ResolvedRetryConfiguration

      protected ResolvedRetryConfiguration()

  • Method Details

    • hasRetryTopic

      protected boolean hasRetryTopic()

    • hasNoRetryTopic

      protected boolean hasNoRetryTopic()