Flink-kafka consume errors.


raghunittala@...
 

I have installed strimzi kafka on minikube and also flink operator (provided by spotify) on minikube (both are installed on different namespaces). I have done minikube tunnelling and with that, I am able to issue command line kafka commands with localhost:9094 as the bootstrap server address/broker list. I'm able to create the topics, consume from and publlish to with 127.0.0.1:9094. I wrote a sample kafka producer in java that publishes several messages to kafka topic and that is also working fine with "localhost:9094"

When I try to consume from flink, with broker list as "127.0.0.1:9094", I end up in below exception:

I'm not able to understand, why with flink I'm not able to consume where in kafka. Here are the pods that are enabled in the kafka namespace:

Can someone help me on this?

Join cncf-strimzi-dev@lists.cncf.io to automatically receive all group messages.