Hi Mich,
How did you setup your local Kafka cluster, did you produce any message to
it? Seems like you are using a standard local Kafka cluster setup for
testing:
"bootstrap.servers", "localhost:9092" "zookeeper.connect", "localhost:2181"
so probably you need to manually produce some data, probab
Please try new FlinkKafkaConsumer09[String]("md", new SimpleStringSchema(),
properties).setStartFromEarliest() and try again.
Cheers
Minglei.
> 在 2018年6月30日，下午10:08，Mich Talebzadeh 写道：
>
>
> Hi,
>
> I have a streaming topic called "md" that displays test market data.
>
> I have written a s
Hi,
I have a streaming topic called "md" that displays test market data.
I have written a simple program to stream data in via kafka into flinl.
Flink version 1.5
Kafka version 2.12
This is the sample program in scala that compiles ok in start-scala-shell.sh
import java.util.Properties
import
