version:
lastest
JVM version (java -version):
1.8
Description of the problem including expected versus actual behavior:
I constructed BatchConsumeBlockingQueueTrigger with the following arguments:
batchSize:1000 lingerMs:5000
The enqueue qps is 200/s and it spent 50ms to consume the bulk data despite the number of the bulk data.
expected behavior
the consumer function invoke every 5 seconds with about 1000 data.
actual behavior
the consumer function invoked more than 5 times in 1 seconds and the number of bulk data less than 200.
version:
lastest
JVM version (java -version):
1.8
Description of the problem including expected versus actual behavior:
I constructed BatchConsumeBlockingQueueTrigger with the following arguments:
batchSize:1000 lingerMs:5000
The enqueue qps is 200/s and it spent 50ms to consume the bulk data despite the number of the bulk data.
expected behavior
the consumer function invoke every 5 seconds with about 1000 data.
actual behavior
the consumer function invoked more than 5 times in 1 seconds and the number of bulk data less than 200.