- Flink-kafka consume errors.
Re: Flink-kafka consume errors.
toggle quoted messageShow quoted text
If your Flink is running inside the same Minikube, I guess you should use the "type: internal" listener for it. Your Minikube seems to map the load balancer to 127.0.0.1 - so I have some doubts it if works the same way from inside and outside your Minikube because in each case, 127.0.0.1 will refer to something else.
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 email@example.com to automatically receive all group messages.