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)