Closed samhith-kakarla closed 1 month ago
I will take a look at the other examples too
all but the kafka-in pod is running due to a broker error, which is expected: "level":"info","ts":"2024-05-31T22:31:14.99192722Z","logger":"numaflow.Source-processor","caller":"sarama@v1.43.0/broker.go:205","msg":"Failed to connect to broker my-broker1:19700: dial tcp: lookup my-broker1 on 10.96.0.10:53: no such host","pipeline":"join-on-reduce","vertex":"kafka-in"
Thank you! @samhith-kakarla
fixes #1745