[
https://issues.apache.org/jira/browse/FLINK-40367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-40367:
--------------------------------------
Assignee: Purushottam Sinha
> Make Kafka consumer poll timeout configurable
> ---------------------------------------------
>
> Key: FLINK-40367
> URL: https://issues.apache.org/jira/browse/FLINK-40367
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Reporter: Robert Metzger
> Assignee: Purushottam Sinha
> Priority: Major
> Labels: pull-request-available
>
> Currently, the poll timeout in the Kafka connector is hardcoded to 10 seconds:
> consumer.poll(Duration.ofMillis(POLL_TIMEOUT));
> On an idle partition, this can cause the Flink checkpointing to introduce 10
> seconds delay on the checkpoint (which is bad when using a Kafka
> transactional producer).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
