接上一篇文章,已经在本地成功安装并测试了 Kafka。这篇文章探索如何在 learning-demo 后端项目中集成 Kafka,实现消息的生产和消费。
kafka生产者和消费者的代码
新建一个服务,在用户注册的时候发送到指定的topic消息。

消费者,监听相同的topic,消费消息的行为可以自定义,这里将收到的消息打印出来。

在用户注册的时候发送消息,所以需要修改一下用户注册的服务的代码。
在注册服务的代码里面修改,注册成功之后,发送kafka消息。

启动测试
启动报错了,因为我在项目中使用的redis模板还默认的redis模板不一样

需要新建一个类配置一下redis模板

报错就没有了。