Concerning the KafkaSource, please use the "FlinkKafkaConsumer". Its the new and better KafkaSource. Am 01.09.2015 21:40 schrieb "Jerry Peng" <jerry.boyang.p...@gmail.com>:
> Hello, > > I have some questions regarding how to run one of the > flink-storm-examples, the WordCountTopology. How should I run the job? On > github its says I should just execute > bin/flink run example.jar but when I execute: > > bin/flink run WordCount-StormTopology.jar > > nothing happens. What am I doing wrong? and How can I run the > WordCounttopology via StormWordCountRemoteBySubmitter? > > Also why did you guys get rid of the KafkaSource class? What is the API > now for subscribing to a kafka source? > > Best, > > Jerry >
