Example User Defined Sink Build the docker image, and push make image # Privilege required docker push quay.io/numaio/numaflow-python/sink-log:latest Apply the pipeline kubectl apply -f pipeline-numaflow.yaml