我们有多个kinesis消费者应用程序(KCL 2.0)正在使用来自相同kinesis流的数据。所有消费者都将指标发送到cloud watch,并在cloud watch中显示这些指标。 如果我想明确地理解和扩展到一个消费者应用程序的多个实例。我们怎样才能做到这一点……? 云监控指标Get records iterator age、Incoming data - sum (Count)
我想使用DropWizard中的Guage度量来监控我的线程池大小。
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
2,
2,
1,
TimeUnit.MINUTES,
new ArrayBlockingQueue<Runnable>(100),
new ThreadPoolExecutor.DiscardPolicy());
met