1. 导入依赖

  2. 编写配置文件(consumer.xml),修改配置文件的ip,主题,监听器的全限定类名

  3. 让spring配置文件加载consumer.xml

  4. 可以根据配置文件,编写监听器

  5. 如果要测试发,收消息,一定要在kafka的服务中启动kafka(先启动zk),为了测试服务器上能否收到消息,还要启动一个消费者,来监听消息 ssm中整合kafka(消费者)

相关文章:

  • 2021-10-25
  • 2021-11-14
  • 2021-09-23
  • 2021-03-04
猜你喜欢
  • 2021-11-20
  • 2022-02-08
  • 2021-04-11
  • 2022-12-23
  • 2021-12-12
  • 2021-11-18
  • 2021-05-04
相关资源
相似解决方案