同一个工程消费多个kafka集群的多个topic

openDatabase 发布于 2018/08/14 20:19
阅读 3K+
收藏 1

同一个工程消费多个kafka集群的多个topic

手动根据配置实例KafkaListenerContainerFactory

然后一个kafka集群用 一个KafkaListener注解来处理消息,在方法里在根据当前消息的topic name判断 放到不同的方法类里处理

@KafkaListener(id = "groupId", topics = "${spring.kafka.consumer.topicList}", containerFactory = "根据配置实例化的容器工厂")

topics 这里写的多个topic提示  INVALID_TOPIC_EXCEPTION

 

 

 

加载中
0
openDatabase
openDatabase

是注解写错了。

topics是一个字符串类型的数组

1写法对,2写法错。

返回顶部
顶部