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
