Skip to content

Commit 3c4b1db

Browse files
MINOR: Fix Trace log typo in RecordAccumulator.java (#16487)
1 parent bb3c35b commit 3c4b1db

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -346,7 +346,7 @@ public RecordAppendResult append(String topic,
346346
if (buffer == null) {
347347
byte maxUsableMagic = apiVersions.maxUsableProduceMagic();
348348
int size = Math.max(this.batchSize, AbstractRecords.estimateSizeInBytesUpperBound(maxUsableMagic, compression.type(), key, value, headers));
349-
log.trace("Allocating a new {} byte message buffer for topic {} partition {} with remaining timeout {}ms", size, topic, partition, maxTimeToBlock);
349+
log.trace("Allocating a new {} byte message buffer for topic {} partition {} with remaining timeout {}ms", size, topic, effectivePartition, maxTimeToBlock);
350350
// This call may block if we exhausted buffer space.
351351
buffer = free.allocate(size, maxTimeToBlock);
352352
// Update the current time in case the buffer allocation blocked above.

0 commit comments

Comments
 (0)