我目前正在使用 Amazon Kinesis 和 KCL 实施生产者/消费者场景。
我想通过指标监控我的消费者是否落后SubscribeToShardEvent.MillisBehindLatest。
为了模拟一个缓慢的消费者，我在每个processRecords实现中添加了 3 秒的睡眠时间。
我的假设是，如果我不断地将记录插入流中，我的消费者将会落后。但我的流只看到 0.0 的值。
我看到更高数字的唯一方法是停止我的消费者然后重新开始。在开始的短暂时刻，消费者具有很高的价值，但随后很快就赶上了。
所以我想我的问题是：我怎样才能模拟一个缓慢的消费者，这会在我的监控中引发警报？