Skip to content

Commit

Permalink
Fix potential key exposure in PKQ
Browse files Browse the repository at this point in the history
  • Loading branch information
ocadaruma committed Jun 7, 2024
1 parent aa055ff commit 201e583
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down

0 comments on commit 201e583

Please sign in to comment.