numaflow
numaflow copied to clipboard
Batching with Timeout not working as expected
Describe the bug When given a timeout as T, and batch size at B we want numaflow to return either B messages or read up until T whichever occurs first
Message from the maintainers:
Impacted by this bug? Give it a 👍. We often sort issues this way to know what to prioritize.
For quick help and support, join our slack channel.
Somehow readTimeout is not documented in https://numaflow.numaproj.io/user-guide/reference/pipeline-tuning/, please add it as well.