程序包 com.cdkjframework.kafka.consumer.config

类 KafkaClientAutoConfiguration

java.lang.Object
com.cdkjframework.kafka.consumer.config.KafkaClientAutoConfiguration
@Lazy(false) @Configuration(proxyBeanMethods=false) @EnableConfigurationProperties(KafkaClientConfig.class) @AutoConfigureAfter(org.springframework.boot.autoconfigure.web.reactive.function.client.WebClientAutoConfiguration.class) @ImportAutoConfiguration(ConsumerConfiguration.class) @ConditionalOnBean(Marker.class) public class KafkaClientAutoConfiguration extends Object

  • 构造器详细资料

    • KafkaClientAutoConfiguration

      public KafkaClientAutoConfiguration()

  • 方法详细资料

    • kafkaConsumer

      @Bean @ConditionalOnMissingBean public ConsumerListener kafkaConsumer()
      kafka topic 启动触发器
      返回:
      返回结果