前言 一、准备工作 二、is not in the trusted packages
1.消息发送 2.is not in the trusted packages: [java.util, java.lang] 3.异常解决 三、基于ConditionalGenericConverter转换 总结
前言在日常Kafka使用中，大部分场景下，消息间的传递使用的是JSON格式字符串，同时生产者和消费者使用String序列化和反序列化方式进行处理。这篇博文，将介绍如何使用自定义实体类，在生产者和消费者之间流淌，以及可能出现的问题。
一、准备工作在Kafka中，消息使用byte数组方式进行存储，而为了方便代码处理，在此基础上增加了序列化和反序列化动作。同时，在消息发送时，需要指定序列化方式，消息消费时，需要指定反序列化方式。在之前博文中，我们使用的是String的序列化和反序列化方式。在这里，我们将其修改成JSON的方式。
