Почему Encoder отсутствует в пакете kafka.serializer?

Question

Я пытаюсь закодировать объект класса для отправки с использованием производителя kafka. Класс имеет много атрибутов:

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 не содержит кодировщик ]

Answer 1

Поскольку он устарел, затем удален, и вы должны импортировать некоторый класс сериализатора в org.apache.kafka.common.serialization или написать свой собственный сериализатор

Примечание: использование сериализуемого Java не очень эффективно и определенно не кросс-языксовместимы.