Hi Will, In Kafka's consumer configuration [1] there is a configuration parameter called "auto.offset.reset". Setting it to "smallest" will tell the consumer to start reading a topic from the smallest available offset.
You can pass the configuration using the properties of the Kafka consumer. [1] http://kafka.apache.org/documentation.html#consumerconfigs On Tue, Nov 17, 2015 at 8:55 AM, Miaoyongqiang (Will) < miaoyongqi...@huawei.com> wrote: > Hi, > > > > How can I tell a “FlinkKafkaConsumer” that I want to read from a topic > from the beginning? > > > > Thanks, > > Will >
