DynamoStreams Consumer millisBehindLatest metric

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

DynamoStreams Consumer millisBehindLatest metric

Vinay Patil
Hi,

I am currently using FlinkDynamoStreamsConsumer in Production, for monitoring the lag I am relying on millisBehindLatest metric but this always returns -1 even if the dynamo stream contains million records upfront.

Also, it would be great if we can add a documentation mentioning that Flink supports DynamoStreams

Regards,
Vinay Patil