Kafka消费者困于反序列化

Question

我创建了一个简单的生产者-消费者应用程序，使用自定义序列化器和反序列化器。

在我生成的Message类中添加了一个新方法之后，使用者开始在反序列化时被堆栈。我的生产者使用的是新类（有新方法），消费者使用的是旧类（没有方法）。

public enum MessageType{
    A,
    B,
    C,
}

public class Message implements Serializable {

    protected long id;
    protected MessageType type;

    public Message(int id , MessageType type) {
        this.id=id;
        this.type=type;
    }

public class MessageA extends Message{
    private String name;

    public MessageA(int id, String name) {
        super(id,MessageType.A);
        this.name = name;
    }

public class MessageSerializer implements Serializer<Message> {
    @Override
    public byte[] serialize(String topic, Message msg) {
        return SerializationUtils.serialize(msg);    
}

    @Override
    public void configure(Map<String, ?> configs, boolean isKey) {}

    @Override
    public void close() {}
}

public class MessageDeserializer implements Deserializer<Message> {

    @Override
    public void configure(Map<String, ?> configs, boolean isKey) {}

    @Override
    public Message deserialize(String topic, byte[] data) {
        if(data == null)
            return null;
        log.info("Deserializing msg");
        Message msg= (Message) SerializationUtils.deserialize(data);
        if(msg== null){
            log.warn("Deserialization failed, got null as a result.");
            return null;
        }
        log.info("Deserialization complete");
        return msg;
    }

    @Override
    public void close() {}
    
    }

JSONSerializer/Deserializer可以处理这些类型的修复吗？如果我要使用JSONSerialzier，它应该只关心类的模式，对吗？

Answer 1

如果您使用JSONSerializer，它不应受到对方法的更改的影响--只应受到对数据字段的更改的影响。其他序列化器可以序列化包括方法在内的整个对象。