ashwinpankaj opened a new pull request, #13084:
URL: https://github.com/apache/kafka/pull/13084

   https://issues.apache.org/jira/browse/KAFKA-14598
   
   ConnectRestApiTest sometimes fails with the message
   ```
   ConnectRestError(404, '<html>\n<head>\n<meta http-equiv="Content-Type" 
content="text/html;charset=ISO-8859-1"/>\n<title>Error 404 Not 
Found</title>\n</head>\n<body><h2>HTTP ERROR 404 Not 
Found</h2>\n<table>\n<tr><th>URI:</th><td>/connector-plugins/</td></tr>\n<tr><th>STATUS:</th><td>404</td></tr>\n<tr><th>MESSAGE:</th><td>Not
 
Found</td></tr>\n<tr><th>SERVLET:</th><td>-</td></tr>\n</table>\n\n</body>\n</html>\n',
 'http://172.31.1.75:8083/connector-plugins/')
   ```
   This happens because ConnectDistributedService.start() by default waits till 
the the line`Joined group at generation ..` is visible in the logs.
   
   In most cases this is sufficient. But in the cases where the test fails, we 
see that this message appears even before Connect RestServer has finished 
initialization.
   ```
   [2022-12-15 15:40:29,064] INFO [Worker clientId=connect-1, 
groupId=connect-cluster] Joined group at generation 2 with protocol version 1 
and got assignment: Assignment
   Unknown macro: {error=0, 
leader='connect-1-07d9da63-9acb-4633-aee4-1ab79f4ab1ae', leaderUrl='http}
   with rebalance delay: 0 
(org.apache.kafka.connect.runtime.distributed.DistributedHerder)
   
   [2022-12-15 15:40:29,560] INFO 172.31.5.66 - - [15/Dec/2022:15:40:29 +0000] 
"GET /connector-plugins/ HTTP/1.1" 404 375 "-" "python-requests/2.24.0" 71 
(org.apache.kafka.connect.runtime.rest.RestServer)
   [2022-12-15 15:40:29,579] INFO REST resources initialized; server is started 
and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer)
   ```
   
   * Ran the fixed test. In connect logs we can see that `GET /connectors` is 
called multiple times till it returns 200 OK. This shows that the test waits 
till Connect REST service is up.
   
   ### Committer Checklist (excluded from commit message)
   - [ ] 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

Reply via email to