flink消费kafka

Question

flink消费kafka，在写source时用filter算子过滤掉某条数据后，会消费掉该kafka数据吗，该消息的偏移量会提交吗。FlinkKafkaConsumer010中如何获取kafka的偏移量呢，有大佬知道吗

Answer 1

对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。
对消费者来说， 你只需要消费下一条就行了。
至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地记住的，否则就重复消费了。