Hi Navneeth, The exception you are getting is a Kafka NetworkException. From the provided information I can’t really tell much and can only guess, but are you sure that the client / broker versions match? It seems like that you are using 0.10; the default client version in the Flink Kafka 0.10 connector is 0.10.2.1.
Cheers, Gordon On 14 December 2017 at 5:37:31 AM, Navneeth Krishnan (reachnavnee...@gmail.com) wrote: I have a kafka source and sink in my pipeline and when I start my job I get this error and the job goes to failed state. I checked the kafka node and everything looks good. Any suggestion on what is happening here? Thanks.
