confluentinc / confluentinc/parallel-consumer

Feature suggestion: Minimum batch size + batch max wait time

Open
#560 7 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
299
Forks
172
PR merge metrics
No merged PRs in 30d

Description

Hi Team, Does it make sense to support `minimumBatchSize` with `maxTimeToWait` in Parallel consumer? The idea is that I want to use the PC as a micro batch consumer, but since my consumers are faster than my stream I get 1 event most of the time, I do get larger batches but only when system is in lag. Seems that I am not the only one that consider that: [see](https://github.com/confluentinc/parallel-consumer/issues/551)
What do you think about this idea?
Is this something you don't want to support? or it is just not the focus right now?

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.