Wie kann flink die neuesten Daten von kafka lesen?

Question

Nun liest flink in meinem Szenario immer die neusten Daten von kafka. Zum Beispiel kafka Produkte:

log1

log2

log3

Beim Lesen wird nur log 3 benötigt.

Kafka Verbraucher API, seekToEnd() kann es tun.

Hat FlinkKafkaConsumer die gleiche Funktion?

Answer 1

Flink 1.3 hat diese Funktion.

FlinkKafkaConsumer09 flinkKafkaConsumer09 = new FlinkKafkaConsumer09 <> (properties.getProperty ("Thema"), neuer RowDeserializationSchema (properties.getProperty ("Separator"), result), Eigenschaften);

flinkKafkaConsumer09.setStartFromLatest();