imaffe edited a comment on issue #540:
URL:
https://github.com/apache/rocketmq-externals/issues/540#issuecomment-634828644
WorkerSinkTask#pullMessageFromQueues(), this method can block up to 20
seconds, however the consumer pull timeout is set to 3 seconds, which is very
weird.
1. We need to find out why the actual timeout is not the same as the default
value, we can do this by adding a try catch block.
```
log.info("START pullBlockIfNotFound, time started : {}",
System.currentTimeMillis());
// TODO this method blocked longer than expected
final PullResult pullResult =
consumer.pullBlockIfNotFound(entry.getKey(), "*", entry.getValue(),
MAX_MESSAGE_NUM);
long currentTime = System.currentTimeMillis();
log.info("INSIDE pullMessageFromQueues, time elapsed : {}",
currentTime - startTimeStamp);
```
However as I observe the pullResult actually executed for 20 seconds, we
need to check why that is happening.
EDIT: I found where to configure this property, now it's 5 seconds.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
