分类：boot整合kafka

2022
02-11

使用spring boot 整合kafka,延迟启动消费者

springboot整合kafka,延迟启动消费者springboot整合kafka的时候一般使用@KafkaListener来设置消费者，但是这种方式在spring启动的时候就会立即开启消费者。如果有需要根据配置信息延迟开启指定的消费者就不能使用这种方式。参考了类：KafkaListenerAnnotationBeanPostProcessor，我提取了一部分代码。可以根据需要随时动态的开启消费者。还可以很方便的启动多个消费者。为了方便使用，我自定义了一个注解：importorg.springfra... 继续阅读 >