Flink消费Kafka数据指定offset的五种模式

Flink消费Kafka数据指定offset的五种模式

代码如下：

FlinkKafkaConsumer consumer = new FlinkKafkaConsumer("topic", new SimpleStringSchema(), props); /*** Flink从topic中最初的数据开始消费*/consumer.setStartFromEarliest(); /*** Flink从topic中指定的时间点开始消费，指定时间点之前的数据忽略*/consumer.setStartFromTimestamp(1559801580000l); /*** Flink从topic中指定的offset开始，这个比较复杂，需要手动指定offset*/consumer.setStartFromSpecificOffsets(offsets); /*** Flink从topic中最新的数据开始消费*/consumer.setStartFromLatest(); /*** Flink从topic中指定的group上次消费的位置开始消费，所以必须配置group.id参数*/consumer.setStartFromGroupOffsets();

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。