Kafka serialization

Question

@Override
public byte[] serialize(String topic, EventLegalPlanInstanceLifecycleChange record) {
return this.serializeImpl(this.getSubjectName(topic,this.isKey,record),record);
}

使用上面的代码，我得到以下错误:

required: String,boolean,Object,ParsedSchema
found: String,boolean,EventLegalPlanInstanceLifecycleChange
reason: actual and formal argument lists differ in length

Answer 1

如错误所示，您缺少ParsedSchema的实例，这是Confluent Schema Registry客户端的一个类。

如果EventLegalPlanInstanceLifecycleChange是从Avro/Protobuf生成的类，那么你不需要实现自己的Serializer。