Hi Stefanos,
this looks like an issue with Kafka. Which version does your broker have?
Can you check the logs of the broker you are trying to connect to?
On Fri, Mar 11, 2016 at 5:27 PM, Stefanos Antaris <
antaris.stefa...@gmail.com> wrote:
> Hi to all,
>
> i am trying to make Flink to work with
Hi to all,
i am trying to make Flink to work with Kafka but i always have the following
exception. It works perfect on my laptop but when i try to use it on the
cluster it always fails.
java.lang.Exception
at
org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.run(Lega
