You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2019/06/21 16:55:44 UTC
[kafka] branch trunk updated: KAFKA-8563: Remove redundant
`NetworkSend.sizeDelimit()` method (#6967)
This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4d1d995 KAFKA-8563: Remove redundant `NetworkSend.sizeDelimit()` method (#6967)
4d1d995 is described below
commit 4d1d995a115939da51a8ad93f9df91e05ec0c808
Author: Karan Kumar <ka...@gmail.com>
AuthorDate: Fri Jun 21 22:25:31 2019 +0530
KAFKA-8563: Remove redundant `NetworkSend.sizeDelimit()` method (#6967)
Reviewers: Ismael Juma <is...@juma.me.uk>
---
.../src/main/java/org/apache/kafka/common/network/NetworkSend.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
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 8820059..94abc64 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) {