osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: How to get Kafka record's timestamp using Flink's KeyedDeserializationSchema?


Thanks. Is there an alternative way to obtain the Kafka record timestamps using FlinkKafkaConsumer?

‐‐‐‐‐‐‐ Original Message ‐‐‐‐‐‐‐
On Friday, November 16, 2018 9:59 AM, Andrey Zagrebin <andrey@xxxxxxxxxxxxxxxxx> wrote:

Hi,

I think this is still on-going effort. You can monitor the corresponding issues [1] and [2].

Best,
Andrey

[1] https://issues.apache.org/jira/browse/FLINK-8500

On 16 Nov 2018, at 09:41, Flink Developer <developer143@xxxxxxxxxxxxxx> wrote:

Kafka timestamp