我已经用avromaven插件从avro模式生成了avrojava类。我将avro类序列化为字节数组，并将其写入kafka主题。
然后我有一个kafka流，它试图操纵avro数据来做一些事情。在反序列化过程中，我从同一个类中得到一个classcastexcition。我了解到这个问题是由于avro在fallback（类加载器的一个新示例）上使用了不同的类加载器而产生的。
有没有一种方法可以强制avro使用调用者的类加载器或类似的东西？
kafkastream属性

this.props = new Properties();
        this.props.put(StreamsConfig.APPLICATION_ID_CONFIG, "test");
        this.props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        this.props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
        this.props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.ByteArray().getClass());

我正在使用一个字符串键和序列化的avro的字节数组，然后我需要手动反序列化avro的负载。我使用avro的解码器反序列化如下：

AvroPayload stp = AvroPayload.fromByteBuffer(ByteBuffer.wrap(bytes));

或者像这样：

AvroPayload stp = AvroPayload.getDecoder().decode(ByteBuffer.wrap(bytes));

在第一个版本中，我可以看到，如果我保持在avro生成的类上下文中，字节数组被正确地反序列化到avropayload类中。返回新示例可能会引发 ClassCastException