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

Posted to dev@flink.apache.org by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/11 17:58:00 UTC

[jira] [Created] (FLINK-40367) Make Kafka consumer poll timeout configurable

Robert Metzger created FLINK-40367:
--------------------------------------

             Summary: 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


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)