flink如何從kafka中讀取最新數據

Question

現在，在我的情況下，flink每次都會從kafka中讀取最新數據。 例如， 卡夫卡產品：

LOG1

LOG2

log3中

讀取時，只需要log3中。

Kafka消費者API，seekToEnd（）可以做到這一點。

FlinkKafkaConsumer有相同的功能嗎？

Answer 1

Flink 1.3具有此功能。

FlinkKafkaConsumer09 flinkKafkaConsumer09 =新FlinkKafkaConsumer09 <>（properties.getProperty（ 「主題」），新RowDeserializationSchema（properties.getProperty（ 「分離器」），與resultType），屬性）;

flinkKafkaConsumer09.setStartFromLatest（）;