diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java index 4bef71a1..e6c9f3b0 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java @@ -45,7 +45,9 @@ public class SimpleRecordsFetcherFactory implements RecordsFetcherFactory { .setDaemon(true) .setNameFormat("prefetch-cache-" + shardId + "-%04d") .build()), - idleMillisBetweenCalls, metricsFactory, "processTask"); + idleMillisBetweenCalls, + metricsFactory, + "ProcessTask"); } }