一、报错重现

Kafka默认情况下使用StringSerializer对键key和值value进行序列化，在这种情况下，只能是字符串才可以进行序列化。如果发送的消息不是字符串或者自定义类型，将出现 标题 的错误。

二、解决办法

既然是序列化器导致的错误，那么我们修改其序列化方式即可。

①引用spring框架的kafka序列化器

        A.maven引入依赖

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.6.5</version>
</dependency>

        B.将消费者和生产者指定为其他的序列化对象

props.put("key.serializer","org.springframework.kafka.support.serializer.JsonSerializer") ;
props.put("value.serializer","org.springframework.kafka.support.serializer.JsonSerializer");

②自定义序列化器

public class UserSerializer implements Serializer<Hotel> {
    
    @Override
    public byte[] serialize(String topic, Hotel hotel) {
        if (data==null){
            return null;
        }
        String json = JSON.toJSONString(hotel);  #阿里的fastjson.JSON
        return json.getBytes(StandardCharsets.UTF_8);
    }
}