16 lines (13 loc) · 480 Bytes

Example Python User Defined Function using Kafka sink

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
```