Juho Autio created FLINK-9183:

             Summary: 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

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:

This message was sent by Atlassian JIRA

Reply via email to