From e94136f1075963f4238a69055a54e2eb823d37b1 Mon Sep 17 00:00:00 2001 From: Robin Han Date: Wed, 19 Nov 2025 19:35:32 +0800 Subject: [PATCH] fix(benchmark): fix compression so it works even when not batching. Signed-off-by: Robin Han --- .../main/java/org/apache/kafka/tools/automq/PerfCommand.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/tools/src/main/java/org/apache/kafka/tools/automq/PerfCommand.java b/tools/src/main/java/org/apache/kafka/tools/automq/PerfCommand.java index 0a1c34753c..0f26c6cb54 100644 --- a/tools/src/main/java/org/apache/kafka/tools/automq/PerfCommand.java +++ b/tools/src/main/java/org/apache/kafka/tools/automq/PerfCommand.java @@ -309,13 +309,10 @@ private List randomPayloads(int size, double randomRatio, int count) { int randomBytes = (int) (size * randomRatio); int staticBytes = size - randomBytes; byte[] staticPayload = new byte[staticBytes]; - r.nextBytes(staticPayload); - if (randomBytes == 0) { // all payloads are the same, no need to create multiple copies return List.of(staticPayload); } - List payloads = new ArrayList<>(count); for (int i = 0; i < count; i++) { byte[] payload = new byte[size];