From 201e5836aa58bb1a066f31b0336da2ffdc8c3cf3 Mon Sep 17 00:00:00 2001
From: Haruki Okada <ocadaruma@gmail.com>
Date: Fri, 7 Jun 2024 14:15:06 +0900
Subject: [PATCH] Fix potential key exposure in PKQ

---
 .../decaton/processor/runtime/internal/QuotaApplierImpl.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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<byte[], byte[]> 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;