[ https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351159#comment-17351159 ]
Josep Prat edited comment on KAFKA-12511 at 5/25/21, 4:00 PM: -------------------------------------------------------------- Seen in: [https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-10758/1/testReport/kafka.network/DynamicConnectionQuotaTest/Build___JDK_8_and_Scala_2_12___testDynamicConnectionQuota__/] {code:java} java.net.SocketException: Broken pipe (Write failed) at java.net.SocketOutputStream.socketWrite0(Native Method) at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111) at java.net.SocketOutputStream.write(SocketOutputStream.java:134) at java.io.DataOutputStream.writeInt(DataOutputStream.java:198) at kafka.server.BaseRequestTest.sendRequest(BaseRequestTest.scala:85) at kafka.server.BaseRequestTest.sendWithHeader(BaseRequestTest.scala:139) at kafka.server.BaseRequestTest.send(BaseRequestTest.scala:134) at kafka.server.BaseRequestTest.sendAndReceive(BaseRequestTest.scala:113) at kafka.network.DynamicConnectionQuotaTest.verifyConnection(DynamicConnectionQuotaTest.scala:340) at kafka.network.DynamicConnectionQuotaTest.createAndVerifyConnection(DynamicConnectionQuotaTest.scala:333) at kafka.network.DynamicConnectionQuotaTest.testDynamicConnectionQuota(DynamicConnectionQuotaTest.scala:355){code} was (Author: josep.prat): Seen in: [https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-10758/1/testReport/kafka.network/DynamicConnectionQuotaTest/Build___JDK_8_and_Scala_2_12___testDynamicConnectionQuota__/] {code:java} java.lang.AssertionError: Did not receive all 1 records from topic output- within 60000 ms, currently accumulated data is [] Expected: is a value equal to or greater than <1> but: <0> was less than <1> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:610) at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:368) at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:336) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:606) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:579) at org.apache.kafka.streams.integration.KTableKTableForeignKeyInnerJoinMultiIntegrationTest.verifyKTableKTableJoin(KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java:199) at org.apache.kafka.streams.integration.KTableKTableForeignKeyInnerJoinMultiIntegrationTest.shouldInnerJoinMultiPartitionQueryable(KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java:185) {code} > Flaky test > DynamicConnectionQuotaTest.testDynamicListenerConnectionCreationRateQuota() > -------------------------------------------------------------------------------------- > > Key: KAFKA-12511 > URL: https://issues.apache.org/jira/browse/KAFKA-12511 > Project: Kafka > Issue Type: Bug > Reporter: dengziming > Priority: Minor > > First time: > Listener PLAINTEXT connection rate 14.419389476913636 must be below > 14.399999999999999 ==> expected: <true> but was: <false> > Second time: > Listener EXTERNAL connection rate 10.998243336133811 must be below > 10.799999999999999 ==> expected: <true> but was: <false> > details: > https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-10289/4/testReport/junit/kafka.network/DynamicConnectionQuotaTest/Build___JDK_11___testDynamicListenerConnectionCreationRateQuota__/ -- This message was sent by Atlassian Jira (v8.3.4#803005)