|
我自己遇到的问题 我之前的项目中就是因为有好几个不同的topic，不同的方法对应的注解@KafkaListener里边我直接写的(topics = { }, containerFactory = “kafkaListenerContainerFactory”)，这两个参数，然后上边topic中放不同的名称就行，之前一点问题都没有。就在前两天的时候，突然kafka不自动实时消费了，找了好久的问题，服务器上三个集群kafka和zookeeper都启动了，集群状态也查看了，kafka在linux命令试了一下生产和消费消息也没问题（基本命令操作，请看最后边）。后来准备使用KafkaListenerEndpointRegistry这个类，可以手动控制启动和停止监听，这个类中需要配置id（不知道这个类的，可以参考这个 Little Coder）。写好之后，启动项目，正准备发送启动请求，结果一看已经在自动消费了，后来我就给每个方法的注解@KafkaListener配置上了不同的id参数@KafkaListener(topics = { }, containerFactory = “kafkaListenerContainerFactory”, id = “”)，OK！至此监听自动不消费的问题解决了。
|