dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Workaround for KAFKA-4090

Browse Source
This commit is contained in:
Andrii Shvaika 2022-02-14 15:54:54 +02:00
parent ebd563d9f5
commit d10e65095f
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
application/src/main/java/org/apache/kafka/common/network/NetworkReceive.java
View File

@ -112,7 +112,6 @@ public class NetworkReceive implements Receive {
if (receiveSize < 0) if (receiveSize < 0)
throw new InvalidReceiveException("Invalid receive (size = " + receiveSize + ")"); throw new InvalidReceiveException("Invalid receive (size = " + receiveSize + ")");
if (maxSize != UNLIMITED && receiveSize > maxSize) { if (maxSize != UNLIMITED && receiveSize > maxSize) {
var t = Thread.currentThread();
throw new ThingsboardKafkaClientError("Invalid receive (size = " + receiveSize + " larger than " + maxSize + ")"); throw new ThingsboardKafkaClientError("Invalid receive (size = " + receiveSize + " larger than " + maxSize + ")");
} }
requestedBufferSize = receiveSize; //may be 0 for some payloads (SASL) requestedBufferSize = receiveSize; //may be 0 for some payloads (SASL)