You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/01 10:08:00 UTC
[jira] [Created] (FLINK-8820) FlinkKafkaConsumer010 reads too many
bytes
Fabian Hueske created FLINK-8820:
------------------------------------
Summary: FlinkKafkaConsumer010 reads too many bytes
Key: FLINK-8820
URL: https://issues.apache.org/jira/browse/FLINK-8820
Project: Flink
Issue Type: Bug
Components: Kafka Connector
Affects Versions: 1.4.0
Reporter: Fabian Hueske
A user reported that the FlinkKafkaConsumer010 very rarely consumes too many bytes, i.e., the returned message is too large. The application is running for about a year and the problem started to occur after upgrading to Flink 1.4.0.
The user made a good effort in debugging the problem but was not able to reproduce it in a controlled environment. It seems that the data is correctly stored in Kafka.
Here's the thread on the thread on the user mailing list for a detailed description of the problem and analysis so far: https://lists.apache.org/thread.html/1d62f616d275e9e23a5215ddf7f5466051be7ea96897d827232fcb4e@%3Cuser.flink.apache.org%3E
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)