[jira] [Created] (FLINK-16475) PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16475) PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable

Shang Yuanchun (Jira)
Jason Kania created FLINK-16475:
-----------------------------------

             Summary: PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable
                 Key: FLINK-16475
                 URL: https://issues.apache.org/jira/browse/FLINK-16475
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.9.2
         Environment: Not releveant
            Reporter: Jason Kania


The messageReceiveTimeoutMs value in the PulsarConsumerSource class is hardcoded to 100ms but should be configurable to accommodate different hardware setups such as developer labs where the performance level may not be as critical.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)