numaproj

numaproj/numaflow

Kubernetes-native platform to run massively parallel data/streaming jobs

29 good first / help-wanted issues · Rust · last activity Jul 1, 2026

2.8K stars 161 forks 2.8K watchers Rust Apache License 2.0
data-processing hacktoberfest k8s kubernetes map-reduce pipeline stream-processing
View on GitHub Website
29 Open Issues Need Help Last updated: Jul 1, 2026

Open Issues Need Help

View All on GitHub
Support SQS's native DLQ functionality 11 days ago
enhancement good first issue area/source nice-to-have dataplane rust
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
ROS 2 as a pipeline source 26 days ago
enhancement help wanted area/source robotics
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Zenoh as a pipeline source 26 days ago
enhancement help wanted area/source robotics
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Increase log level for ERROR "nats: Maximum Payload Violation" about 1 month ago
enhancement good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Encapsulate NackOptions in Box 3 months ago
good first issue area/source area/isb dataplane rust
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Implement supported nack options in pulsar 4 months ago
enhancement good first issue area/source dataplane rust
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Rollup unhealthy vertex reason to pipeline 4 months ago
enhancement good first issue opex area/controller nice-to-have
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
containerTemplate for all Pod Containers 7 months ago
enhancement help wanted
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
more type-safe version compatibility check for monovertex 10 months ago
enhancement good first issue rust area/monovertex
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Enable Opentelemetry protocol for metrics 10 months ago
good first issue help wanted
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Support for mulitiple kafka topics by regexp 12 months ago
enhancement good first issue help wanted
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Source Transformer about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Docs: Use MKDocs Content Tabs for Go/Java/Python examples about 1 year ago
documentation good first issue help wanted
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Store about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Session Reduce about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Source about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Sink about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Reduce about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Map about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Accumulator about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use MKDocs Content Tabs for Side Inputs about 1 year ago
documentation good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
ASP.NET.CORE 9 Compatibility about 1 year ago
bug good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
globalization/Internationlization for numaflow UI about 1 year ago
enhancement help wanted area/ui
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
inconsistent contract on edge:conditions: tags about 1 year ago
bug good first issue
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Show fallback sink container icon in both Pipeline and MonoVertex UI about 1 year ago
enhancement good first issue nice-to-have
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
Use WriteOncePerPod as default access mode for PVC about 1 year ago
good first issue help wanted area/controller
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
aws-smithy-mocks-experimental is deprecated, sqs extension should use the stable aws-smithy-mocks over 1 year ago

AI Summary: The Numaflow SQS extension uses a deprecated AWS Smithy mocks library. The task is to update the extension to use the stable `aws-smithy-mocks` crate instead of the deprecated `aws-smithy-mocks-experimental` crate, resolving the deprecation warning.

Complexity: 3/5
good first issue help wanted rust
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
UI Health filter has no effect on Unhealthy pipelines over 1 year ago

AI Summary: The issue describes a bug in the Numaflow UI where the health filter doesn't correctly filter unhealthy pipelines. The task is to debug and fix this filtering issue in the UI, ensuring that only pipelines with the selected health status are displayed. This involves investigating the filtering logic within the UI codebase and correcting any errors that prevent the proper filtering of unhealthy pipelines.

Complexity: 4/5
bug good first issue area/ui
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing
[Rust] Generator source is not decoding base64 encoded value blob over 1 year ago

AI Summary: The Numaflow Rust Generator source needs to be fixed to decode base64 encoded values in the `valueBlob` field of its configuration. Currently, it sends the base64 encoded string instead of the decoded value to the Pulsar sink. The fix involves modifying the `components.rs` file to decode the base64 string before sending it.

Complexity: 3/5
bug good first issue area/source rust
numaproj/numaflow
2.8K

Kubernetes-native platform to run massively parallel data/streaming jobs

Rust
#data-processing#hacktoberfest#k8s#kubernetes#map-reduce#pipeline#stream-processing