-
Install Kafka in the Kubernetes cluster
kubectl apply -f https://raw.githubusercontent.com/numaproj/numaflow/main/config/apps/kafka/kafka-minimal.yaml
-
Build the docker image and import into k3d
docker build -t test-python-udf:v1 . && k3d image import docker.io/library/test-python-udf:v1
-
Apply the pipeline
kubectl apply -f pipeline-numaflow.yaml
forward_message
Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|
parent directory.. | ||||