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];