[jira] [Closed] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes

["Till Rohrmann (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Till Rohrmann closed FLINK-8820.
--------------------------------
       Resolution: Cannot Reproduce
    Fix Version/s:     (was: 1.7.1)
                       (was: 1.5.6)
                       (was: 1.6.3)
                       (was: 1.8.0)

Please reopen if issue should reoccur.

> 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
>            Priority: Critical
>
> 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)