[ 
https://issues.apache.org/jira/browse/FLINK-25818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485127#comment-17485127
 ] 

Fabian Paul commented on FLINK-25818:
-------------------------------------

Merged in release-1.14: e074805bf64ea40407ee31d310043bbb5572d351

Merged in release-1.13: 91e3acf7e9ce66e9faaa2d55b3a78e3b76f49374

> Add explanation how Kafka Source deals with idleness when parallelism is 
> higher then the number of partitions
> -------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-25818
>                 URL: https://issues.apache.org/jira/browse/FLINK-25818
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / Kafka, Documentation
>    Affects Versions: 1.15.0
>            Reporter: Martijn Visser
>            Assignee: Martijn Visser
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> Add a section to the Kafka Source documentation to explain what happens with 
> the Kafka Source with regards to idleness when parallelism is higher then the 
> number of partitions



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

Reply via email to