KafkaConfluent的GenericAvroDeserializer无法反序列化Bytesavro类型数据。

首先，确认生成数据时使用的序列化方法。如果使用了特定的类库或工具，需要在反序列化时使用相同的方法。其次，为GenericAvroDeserializer设置正确的默认值。以下是一个示例代码：

import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
import io.confluent.kafka.serializers.KafkaAvroDeserializer;
import org.apache.avro.generic.GenericRecord;
import org.apache.kafka.common.serialization.Deserializer;

import java.util.Map;

public class BytesAvroDeserializer implements Deserializer<GenericRecord> {
    private KafkaAvroDeserializer kafkaAvroDeserializer;

    @Override
    public void configure(Map<String, ?> props, boolean isKey) {
        kafkaAvroDeserializer = new KafkaAvroDeserializer();
        props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://localhost:8081");
        kafkaAvroDeserializer.configure(props, isKey);
    }

    @Override
    public GenericRecord deserialize(String topic, byte[] data) {
        return (GenericRecord) kafkaAvroDeserializer.deserialize(topic, data);
    }

    @Override
    public void close() {
        kafkaAvroDeserializer.close();
    }
}

在上述代码中，BytesAvroDeserializer实现了Deserializer接口，同时使用Kafka Avro Deserializer来解析数据。借助AvroRecord中的记录模板，可将此代码适用于处理由指定的模板数据生成的数据。