Skip to content

BatchConsumeBlockingQueueTrigger doesn't consume data with expected bulk size #9

Open
@liudunxu

Description

@liudunxu

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.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions