[ https://issues.apache.org/jira/browse/FLINK-9183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16439700#comment-16439700 ]
ASF GitHub Bot commented on FLINK-9183: --------------------------------------- Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5858 I'll merge it on `master`, `release-1.5` and `release-1.4` > 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)