[
https://issues.apache.org/jira/browse/FLINK-25706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-25706.
----------------------------------
Resolution: Duplicate
> 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
> Priority: Major
>
> 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)
