我正在用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)这个错误的来源是什么？
解决办法是什么？
我在哪里可以找到更多的日志或做一些事情来获得额外的调试信息？
谢谢您
1条答案
按热度按时间cedebl8k1#
这个错误的来源是什么？
数据的序列化方式似乎与您尝试反序列化数据的方式不同。
解决办法是什么？
确保在两端使用相同的代码对数据进行序列化和反序列化。我怀疑存在版本或模式不匹配。
我在哪里可以找到更多的日志或做一些事情来获得额外的调试信息？
flink的taskmanagers运行kafka消费程序，将记录有关读取进程的信息。