Sidhant Kohli

Batching with Timeout not working as expected

1

**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...

# Summary There was a new package added for nats-go here https://github.com/nats-io/nats.go/releases/tag/v1.26.0 ``` JetStream Simplified API: This new API overhauls whole nats.go JetStream API and will eventually deprecate the legacy...

verify if the de-duplication logic is working as expected

1

--- We need to verify the functionality of the Dedupe logic **Message from the maintainers**: Impacted by this bug? Give it a 👍. We often sort issues this way to...

# Summary What change needs making? Need to add the feature to auto reload any policy changes in the RBAC file during runtime. When would you use this? To update...

# Summary --- Currently, we are not testing certain flows such as server start for Async in our UT. Need to add these back to coverage and ensure functionality 1)...

is stream maxBytes the total RAM memory required per stream?

1

Highlighting observations in comments as I'm progressing

containerTemplate gets propagated to initContainer in spec

1

**Describe the bug** While applying an containerTemplate to a vertex, it gets partially propagated to the initContainer spec as well causing a mismatch in spec and issues in reconciler. **To...

**Describe the bug** A clear and concise description of what the bug is. - We are able to set the replicas above the max scale limit defined. Eg: Max defined...

UI for a join vertex will show consolidated buffer pending

1

**Describe the bug** In case of a join vertex with a single buffer, we will see the pending messages on the UI to be replicated for all edges. This can...

Discussed and felt that having the operation (ie Map, Reduce, Transform) -> to be the action here. So keeping mapper, reducer, transformer would be consistent. And the the prefix can...