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 c
Hi,
I'm receiving this error and due to which I'm not able to run my job. Any
help is greatly appreciated. Thanks.
On Tue, Dec 12, 2017 at 10:21 AM, Navneeth Krishnan <
reachnavnee...@gmail.com> wrote:
> Hi,
>
> I have a kafka source and sink in my pipeline and when I start my job I
> get this e
Hi,
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.
java.lang.Exception: Failed to send data to Kafka: The server
disconne
