diff --git a/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/QuotaApplierImpl.java b/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/QuotaApplierImpl.java index 7fcdb723..e7ca3566 100644 --- a/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/QuotaApplierImpl.java +++ b/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/QuotaApplierImpl.java @@ -17,7 +17,6 @@ package com.linecorp.decaton.processor.runtime.internal; import java.time.Duration; -import java.util.Arrays; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; @@ -71,7 +70,7 @@ public boolean apply(ConsumerRecord record, try { topic = callback.apply(record, quotaUsage.metrics()); } catch (Exception e) { - log.error("Exception thrown from the quota callback for key: {}", Arrays.toString(record.key()), e); + log.error("Exception thrown from the quota callback", e); metrics.shapingQueueingFailed.increment(); completion.complete(); return;