在learning-demo项目中集成Kafka代码

星期一, 4月 20, 2026 | 1分钟阅读 | 更新于 星期一, 4月 20, 2026

@

接上一篇文章,已经在本地成功安装并测试了 Kafka。这篇文章探索如何在 learning-demo 后端项目中集成 Kafka,实现消息的生产和消费。

kafka生产者和消费者的代码

新建一个服务,在用户注册的时候发送到指定的topic消息。

生产者代码

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

消费者代码

在用户注册的时候发送消息,所以需要修改一下用户注册的服务的代码。

在注册服务的代码里面修改,注册成功之后,发送kafka消息。

修改注册服务

启动测试

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

启动报错

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

配置Redis模板

报错就没有了。

© 2026 My Blog

🌱 Powered by Hugo with theme Dream.