Package com.flowable.spring.boot.eventregistry

Class EventRegistryAutoConfiguration.EventRegistryKafkaConfiguration

java.lang.Object
com.flowable.spring.boot.eventregistry.EventRegistryAutoConfiguration.EventRegistryKafkaConfiguration
Enclosing class:
EventRegistryAutoConfiguration
@Configuration(proxyBeanMethods=false)
@ConditionalOnBean(org.springframework.kafka.core.KafkaOperations.class)
public static class EventRegistryAutoConfiguration.EventRegistryKafkaConfiguration
extends java.lang.Object

  • Constructor Summary

    Constructors 
    Constructor Description
    EventRegistryKafkaConfiguration()  

  • Method Summary

    Modifier and Type Method Description
    org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor kafkaChannelDefinitionProcessor​(org.springframework.kafka.config.KafkaListenerEndpointRegistry endpointRegistry, org.springframework.kafka.core.KafkaOperations<java.lang.Object,​java.lang.Object> kafkaOperations)  

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

  • Method Details

    • kafkaChannelDefinitionProcessor

      @Bean("kafkaChannelDefinitionProcessor") @ConditionalOnMissingBean(name="kafkaChannelDefinitionProcessor") public org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor kafkaChannelDefinitionProcessor​(org.springframework.kafka.config.KafkaListenerEndpointRegistry endpointRegistry, org.springframework.kafka.core.KafkaOperations<java.lang.Object,​java.lang.Object> kafkaOperations)