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

Posted to dev@flink.apache.org by "xie (Jira)" <ji...@apache.org> on 2022/08/08 10:58:00 UTC

[jira] [Created] (FLINK-28870) Modify the pulsar default consumption rate

xie created FLINK-28870:
---------------------------

             Summary: Modify the pulsar default consumption rate
                 Key: FLINK-28870
                 URL: https://issues.apache.org/jira/browse/FLINK-28870
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Pulsar
            Reporter: xie


when we use the pulsar-connector as source and consume messages,I feel that the consumption rate is a bit low.  It was later found out that it was caused by two default parameters:

PulsarSourceOptions.PULSAR_MAX_FETCH_TIME, default 10s;

PulsarSourceOptions.PULSAR_MAX_FETCH_RECORDS, default 100;

We are small business volume, hope we can improve the consumption speed.

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)