[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529252#comment-17529252
]
lqjacklee commented on KAFKA-13745:
-----------------------------------
[~sagarrao] I want to add the log warning to catch the exception , what do you
think ?
The stack as below :
{code:java}
[2022-03-10 02:59:14,052] WARN [SocketServer listenerType=ZK_BROKER, nodeId=0]
Unexpected error from /127.0.0.1 (channelId=127.0.0.1:43815-127.0.0.1:57029-0);
closing connection (org.apache.kafka.common.network.Selector:619)
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size
= 101 larger than 100)
at
org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:105)
at
org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:452)
at
org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:402)
at
org.apache.kafka.common.network.Selector.attemptRead(Selector.java:674)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:576)
at org.apache.kafka.common.network.Selector.poll(Selector.java:481)
at kafka.network.Processor.poll(SocketServer.scala:1144)
at kafka.network.Processor.run(SocketServer.scala:1047)
at java.lang.Thread.run(Thread.java:748)
{code}
> Flaky
> kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone
> ---------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-13745
> URL: https://issues.apache.org/jira/browse/KAFKA-13745
> Project: Kafka
> Issue Type: Bug
> Reporter: Guozhang Wang
> Assignee: Sagar Rao
> Priority: Blocker
> Fix For: 3.3.0
>
>
> Example:
> https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-11796/7/tests/
> {code}
> org.opentest4j.AssertionFailedError: expected: <false> but was: <true>
> at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55)
> at org.junit.jupiter.api.AssertFalse.assertFalse(AssertFalse.java:40)
> at org.junit.jupiter.api.AssertFalse.assertFalse(AssertFalse.java:35)
> at org.junit.jupiter.api.Assertions.assertFalse(Assertions.java:227)
> at
> kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone(SocketServerTest.scala:751)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
