Class Hierarchy
- java.lang.Object
- org.flowable.eventregistry.spring.kafka.EventPayloadKafkaPartitionProvider (implements org.flowable.eventregistry.spring.kafka.KafkaPartitionProvider)
- org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.BeanFactoryAware, org.flowable.eventregistry.api.ChannelModelProcessor)
- org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor.Configuration
- org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor.ResolvedRetryConfiguration
- org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor.RetryTopicContainerFactoryDecorator (implements org.springframework.kafka.config.KafkaListenerContainerFactory<C>)
- org.flowable.eventregistry.spring.kafka.KafkaChannelMessageListenerAdapter (implements org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener<K,
V>) - org.flowable.eventregistry.spring.kafka.KafkaConsumerRecordInboundEvent (implements org.flowable.eventregistry.api.InboundEvent)
- org.flowable.eventregistry.spring.kafka.KafkaOperationsOutboundEventChannelAdapter (implements org.flowable.eventregistry.api.OutboundEventChannelAdapter<T>)
- org.flowable.eventregistry.spring.kafka.RoundRobinKafkaPartitionProvider (implements org.flowable.eventregistry.spring.kafka.KafkaPartitionProvider)
- org.flowable.eventregistry.spring.kafka.SimpleKafkaListenerEndpoint<K,
V> (implements org.springframework.beans.factory.InitializingBean, org.springframework.kafka.config.KafkaListenerEndpoint)
Interface Hierarchy
- org.flowable.eventregistry.spring.kafka.KafkaMessageKeyProvider<K>
- org.flowable.eventregistry.spring.kafka.KafkaPartitionProvider