ssm中整合kafka(消费者)

导入依赖 编写配置文件(consumer.xml),修改配置文件的ip,主题,监听器的全限定类名 让spring配置文件加载consumer.xml 可以根据配置文件,编写监听器 如果要测试发,收消息,一定要在kafka的服务中启动kafka(先启动zk),为了测试服务器上能否收到消息,还要启动一个消费者,来监听消息
相关文章
相关标签/搜索