Closed gcpagano closed 2 years ago
This is to register a metric in KinesisSpout to trace the MillisBehindLatest returned by the GetRecords API in the recent versions of the AWS SDK.
This is also to register a metric to trace the number of retried tuples in KinesisSpout.
Both metrics are disable by default and can be enable using KinesisSpoutConfig
This is to register a metric in KinesisSpout to trace the MillisBehindLatest returned by the GetRecords API in the recent versions of the AWS SDK.
This is also to register a metric to trace the number of retried tuples in KinesisSpout.
Both metrics are disable by default and can be enable using KinesisSpoutConfig