我正在使用Apache Flink + Kafka实现一个平台。我得到以下错误:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 4416367, only 265 bytes available
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
这个错误的来源是什么?
解决方案是什么?
我在哪里可以找到更多的日志或做一些事情来获得额外的调试信息?
谢谢
这个错误的来源是什么?
似乎数据已被序列化，而不是您试图反序列化它。
解决方案是什么?
确保数据在两端使用相同的代码进行序列化和反序列化。我怀疑有版本或模式不匹配。
我在哪里可以找到更多的日志或做一些事情来获得额外的调试信息?
Flink的TaskManagers，运行Kafka Consumer将记录有关读取过程的信息。