numaflow
numaflow copied to clipboard
numaproj
Kubernetes-native platform to run massively parallel data/streaming jobs
# Summary With session window reducer introduced, we updated our proto for reducer. We need to make corresponding changes to Python SDK. ```[tasklist] ### Tasks - [ ] https://github.com/numaproj/numaflow/issues/1545 -...
We should have a top-level tab to show the clients we support and links to documentation and examples.
# Summary What change needs making? In the User-defined source, I would like to have the ability to add tags to the messages. # Use Cases When would you use...
``` Duplicate message - AAAAAJexQqI=-52-input-0 - 419895504 ``` we occasionally see around 10 per second.
* The home page could display the Numaflow Server version it is currently running on. * The pipeline page could display the Numaflow controller version being used by the pipeline.
# Summary What change needs making? Change in Kafka client to make it resilient to broker outages. # Use Cases When would you use this? When a Kafka broker experiences...
# Summary Numaflow pipeline authors should be able to test the end-to-end pipeline spec and validate the outputs from the Sink based on the data they sent to the Source....
This implements backend for updated stream mapper (`MapStreamBatchFn`) implemented here: https://github.com/numaproj/numaflow-go/pull/129 It allows stream mapper to have readBatchSize > 1. * If `readBatchSize == 1`, the capability today is executed...
