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)
