我们正在尝试使用 Kryo Serializer 序列化我们的应用程序对象，以将它们推送到 kafka 流中。
序列化代码有
private ThreadLocal<Kryo> kryos = new ThreadLocal<Kryo>() {
protected Kryo initialValue() {
Kryo kryo = new Kryo();
kryo.addDefaultSerializer(MyApp.class, new MyAppKyroSerializer());
return kryo;
};
};
序列化方法是:
@Override
public byte[] serialize(String topic, MyApp data) {
ByteBufferOutput output = new ByteBufferOutput(100);
kryos.get().writeObject(output, data);
return output.toBytes();
}
在执行应用程序时，我们收到以下 IllegalAccessError:
Exception in thread "main" java.lang.IllegalAccessError: tried to access field com.esotericsoftware.kryo.io.Output.capacity from class com.esotericsoftware.kryo.io.ByteBufferOutput
at com.esotericsoftware.kryo.io.ByteBufferOutput.<init>(ByteBufferOutput.java:66)
at com.esotericsoftware.kryo.io.ByteBufferOutput.<init>(ByteBufferOutput.java:58)
at com.mycom.serializer.MyAppSerializer.serialize(MyAppSerializer.java:43)
这很奇怪，因为 ByteBufferOutput 扩展了 Output 并且容量是一个 protected 字段。
最佳答案
public byte[] serialize(String topic, Myapp data) {
Output output = new Output(100);
kryos.get().writeObject(output, data);
return output.toBytes();
}
试试这个，我认为这会起作用..
关于java - Kryo Serializer 运行时出现 IllegalAccessError，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38569348/