harlow / kinesis-consumer

Golang library for consuming Kinesis stream data
MIT License
264 stars 90 forks source link

Include MillisBehindLatest in Record for ScanFunc #124

Closed jtackaberry closed 4 years ago

jtackaberry commented 4 years ago

Exposes MillisBehindLatest in the Record struct passed to the ScanFunc callback. My use case is to be able to provide metrics for per-shard lag times, but there could be other uses as well.