Did you double check that your jar does contain the Kafka connector
classes? I would assume that the jar is not assembled correctly.
See her for some help on how to package jars correctly:
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/cluster_execution.html#linking-with-modules-
Hi,
Could anyone help me with the following problem:
I have a flink cluster of a couple of nodes (i am using the old version 0.10).
I am packaging a jar that needs to use kafka connector. When I create the jar
in eclipse I am adding the flink connector dependency and set to be packed with
the j
