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:
