SpringBoot集成kafka收发消息——传递消息为对象

发布时间 2023-07-06 19:29:58作者: 佛系粥米

目前springboot整合后的kafka,因为序列化器是StringSerializer,这个时候如果需要传递对象可以有两种方式

方式一:可以自定义序列化器,对象类型众多,这种方式通用性不强。

方式二:可以把要传递的对象进行转json字符串,接收消息后再转为对象即可,本项目采用这种方式

JSON.toJSONString(user)

string message

JSON.parseObject(message)