C0urante commented on PR #16757: URL: https://github.com/apache/kafka/pull/16757#issuecomment-2261273250
I also believe this would fix the recent flaky failure we saw for the `RestExtensionIntegrationTest::testRestExtensionApi` test case [here](https://ge.apache.org/s/ndddgm7c6ma3c/tests/task/:connect:runtime:test/details/org.apache.kafka.connect.integration.RestExtensionIntegrationTest/testRestExtensionApi()?top-execution=1). The test creates an embedded Connect cluster with a REST extension that tries to read the list of connectors on the cluster while it's being registered. The failure I linked for the test was caused because the request to list the connectors timed out, because the Connect worker was still starting, which in turn happened because the underlying Kafka cluster appeared to still be starting. This test case wasn't improved by our health check endpoint and the way that we use it to ensure that our embedded Connect clusters are healthy after they've started because REST extension registration takes place during cluster startup, before we start querying the health check endpoint. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
