Please try new FlinkKafkaConsumer09[String]("md", new SimpleStringSchema(), properties).setStartFromEarliest() and try again.
Cheers Minglei. > 在 2018年6月30日,下午10:08,Mich Talebzadeh <mich.talebza...@gmail.com> 写道: > > > 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 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.StreamExecutionEnvironment > import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 > import org.apache.flink.streaming.util.serialization.SimpleStringSchema > import org.apache.flink.streaming.util.serialization.DeserializationSchema > //import org.apache.flink.streaming.api.scala._ > import org.apache.flink.streaming.util.serialization.SimpleStringSchema > object Main { > def main(args: Array[String]) { > val env = StreamExecutionEnvironment.getExecutionEnvironment > val properties = new Properties() > properties.setProperty("bootstrap.servers", "localhost:9092") > properties.setProperty("zookeeper.connect", "localhost:2181") > properties.setProperty("group.id <http://group.id/>", "sampleScala") > val stream = env > .addSource(new FlinkKafkaConsumer09[String]("md", new > SimpleStringSchema(), properties)) > .print() > env.execute("Flink Kafka Example") > } > } > > warning: there was one deprecation warning; re-run with -deprecation for > details > defined object Main > > But I do not see any streaming output. > > A naïve question. How do I execute the above compiled object in this shell? > > Thanks > > Dr Mich Talebzadeh > > LinkedIn > https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw > > <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw> > > http://talebzadehmich.wordpress.com <http://talebzadehmich.wordpress.com/> > > Disclaimer: Use it at your own risk. Any and all responsibility for any loss, > damage or destruction of data or any other property which may arise from > relying on this email's technical content is explicitly disclaimed. The > author will in no case be liable for any monetary damages arising from such > loss, damage or destruction. >