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