Hi Fabian.
Thanks. Great contribution! It is working
info] SHA-1: 98d78b909631e5d30664df6a7a4a3f421d4fd33b
[info] Packaging
/home/hduser/dba/bin/flink/md_streaming/target/scala-2.11/md_streaming-assembly-1.0.jar
...
[info] Done packaging.
[success] Total time: 14 s, completed Jul 3, 2018 9:32:25
Hi Mich,
FlinkKafkaConsumer09 is the connector for Kafka 0.9.x.
Have you tried to use FlinkKafkaConsumer011 instead of FlinkKafkaConsumer09?
Best, Fabian
2018-07-02 22:57 GMT+02:00 Mich Talebzadeh :
> This is becoming very tedious.
>
> As suggested I changed the kafka dependency from
>
> ibra
This is becoming very tedious.
As suggested I changed the kafka dependency from
ibraryDependencies += "org.apache.kafka" %% "kafka" % "1.1.0"
to
libraryDependencies += "org.apache.kafka" %% "kafka" % "0.11.0.0"
and compiled and ran the job again anf failed. This is the log file
2018-07-02 21:3
Hi,
This is the code
import java.util.Properties
import java.util.Arrays
import org.apache.flink.api.common.functions.MapFunction
import org.apache.flink.api.java.utils.ParameterTool
import org.apache.flink.streaming.api.datastream.DataStream
import org.apache.flink.streaming.api.environment.Stre
Looks like a version issue , have you made sure that the Kafka version is
compatible?
> On 2. Jul 2018, at 18:35, Mich Talebzadeh wrote:
>
> Have you seen this error by any chance in flink streaming with Kafka please?
>
> org.apache.flink.client.program.ProgramInvocationException:
> java.lan
