为什么编码器不在kafka.serializer包中？

njthzxwz 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(352)

我正在尝试使用kafka producer对要发送的类对象进行编码该类具有许多属性：

public class CarData implements Serializable{
    private String vehicleId;
    private String lon;
    private String lat;
}

我想编码并发送一个cardata对象

producer.send(new ProducerRecord<String, CarData>(topicName, car_data));

但错误如下图所示
[kafka.serializer包不包含编码器]

1条答案

因为它已被弃用，然后被删除，并且您应该在中导入一些序列化程序类 org.apache.kafka.common.serialization 或者编写自己的序列化程序
注意：使用java serializable不是很有效，而且绝对不兼容跨语言。