You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/19 14:55:00 UTC

[jira] [Created] (FLINK-25706) Add idleness to Kafka Source documentation

Martijn Visser created FLINK-25706:
--------------------------------------

             Summary: Add idleness to Kafka Source documentation
                 Key: FLINK-25706
                 URL: https://issues.apache.org/jira/browse/FLINK-25706
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka, Documentation
            Reporter: Martijn Visser
            Assignee: Martijn Visser


All sources based on FLIP-27 do not go automatically in an idle state if the parallelism is higher than the number of partitions.

By accident, we introduced that behavior but now we corrected it so we have to clarify the documentation. The solution is either lowering the parallelism or using {{WatermarkStrategy#withIdleness}}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)