KafkaProducer08 in Flink例外

Question

私は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) 

このエラーの原因は何ですか？

解決策は何ですか。

追加のデバッグ情報を得るために、ログを見つけたり何かを行うことができますか？

は、データはあなたがそれをデシリアライズしようとしているとは異なる連載されているようだあなたに

Answer 1

What is the source of this error?

ありがとうございます。

What is the solution?

データが、両端で同じコードを使用してシリアル化され、デシリアライズされていることを確認します。私はバージョンまたはスキーマの不一致があると思う。

Where can I find more logs or do something to get additional debug info?

Kafka Consumerを実行しているFlinkのTaskManagersは、読み取りプロセスに関する情報を記録します。