diff --git a/clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java b/clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java index 8820059aa79..94abc64bfcb 100644 --- a/clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java +++ b/clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java @@ -24,11 +24,7 @@ import java.nio.ByteBuffer; public class NetworkSend extends ByteBufferSend { public NetworkSend(String destination, ByteBuffer buffer) { - super(destination, sizeDelimit(buffer)); - } - - private static ByteBuffer[] sizeDelimit(ByteBuffer buffer) { - return new ByteBuffer[] {sizeBuffer(buffer.remaining()), buffer}; + super(destination, sizeBuffer(buffer.remaining()), buffer); } private static ByteBuffer sizeBuffer(int size) {