[ https://issues.apache.org/jira/browse/FLINK-9183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske reassigned FLINK-9183: ------------------------------------ Assignee: Juho Autio > Kafka consumer docs to warn about idle partitions > ------------------------------------------------- > > Key: FLINK-9183 > URL: https://issues.apache.org/jira/browse/FLINK-9183 > Project: Flink > Issue Type: Sub-task > Reporter: Juho Autio > Assignee: Juho Autio > Priority: Major > > Looks like the bug FLINK-5479 is entirely preventing > FlinkKafkaConsumerBase#assignTimestampsAndWatermarks to be used if there are > any idle partitions. It would be nice to mention in documentation that > currently this requires all subscribed partitions to have a constant stream > of data with growing timestamps. When watermark gets stalled on an idle > partition it blocks everything. > > Link to current documentation: > [https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html#kafka-consumers-and-timestamp-extractionwatermark-emission] -- This message was sent by Atlassian JIRA (v7.6.3#76005)