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)
