From d10e65095f022b8fa0d0e20abf5964a5f9fc6bb5 Mon Sep 17 00:00:00 2001 From: Andrii Shvaika Date: Mon, 14 Feb 2022 15:54:54 +0200 Subject: [PATCH] Workaround for KAFKA-4090 --- .../java/org/apache/kafka/common/network/NetworkReceive.java | 1 - 1 file changed, 1 deletion(-) diff --git a/application/src/main/java/org/apache/kafka/common/network/NetworkReceive.java b/application/src/main/java/org/apache/kafka/common/network/NetworkReceive.java index 6afc99c69d..38764d08de 100644 --- a/application/src/main/java/org/apache/kafka/common/network/NetworkReceive.java +++ b/application/src/main/java/org/apache/kafka/common/network/NetworkReceive.java @@ -112,7 +112,6 @@ public class NetworkReceive implements Receive { if (receiveSize < 0) throw new InvalidReceiveException("Invalid receive (size = " + receiveSize + ")"); if (maxSize != UNLIMITED && receiveSize > maxSize) { - var t = Thread.currentThread(); throw new ThingsboardKafkaClientError("Invalid receive (size = " + receiveSize + " larger than " + maxSize + ")"); } requestedBufferSize = receiveSize; //may be 0 for some payloads (SASL)