m1a2st opened a new pull request, #17014: URL: https://github.com/apache/kafka/pull/17014
Jira: https://issues.apache.org/jira/browse/KAFKA-17408 When I ran this test case in my local machine, I found the error is ``` org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 9384ms for session id 0x10010be31470000 at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257) ``` In the Jenkis enviroment, the test result message show that get the empty records, thus I guess it is match in this scenerio ``` org.opentest4j.AssertionFailedError: Condition not met within timeout 60000. Did not receive all [KeyValue(americas, 101), KeyValue(europe, 109), KeyValue(asia, 124)] records from topic output-topic (got []) ``` I consider that add the `session.timeout.ms` can fix this flaky - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
