v0.6.0

Major Changes

First official Numaflow release, which contains following major features, check the documentation for all the details.

Check out v0.6 release blog.

• Stream processing pipeline with Source, User Defined Function, and Sink vertices
• Pipeline autoscaling
• Native supported sources and sinks, as well as user defined sinks.
• Watermarks support
• Prometheus metrics
• User interface

Pull Requests

• fix(autoscaling): Ack pending should be included in total pending calculation (#212)
• chore: upgrade xmldom to fix potential security issue (#209)
• fix(autoscaling): Skip autoscaling if vertex is not in running phase (#207)
• chore: add read and written bytes counter (#202)
• chore: Replaced node info text with rich format (#200)
• feat: ISBSVC add support for redis cluster mode (#195)
• ci: add sdk test category (#197)
• docs: add and refine some docs. (#196)
• refactor: move controllers package to pkg/reconciler (#192)
• fix: update udf fetchWatermark and publishWatermark initial values (#193)
• chore: fix security alert (#191)
• chore: generate swagger and schema json (#188)
• chore: probe udsink healthiness (#183)
• chore: clean up code of http protocol udf and udsink (#182)
• fix(docs): readme for UI development (#181)

Contributors

@chromevoid
@whynowy
@Krithika3
@qhuai
@sarabala1979
@kohlisid
@vigith
@yhl25

Installation

kubectl create namespace numaflow-system
kubectl apply -n numaflow-system -f https://raw.githubusercontent.com/numaproj/numaflow/v0.6.0/config/install.yaml