[
https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852247#comment-16852247
]
ASF GitHub Bot commented on KAFKA-8418:
---------------------------------------
rhauch commented on pull request #6840: KAFKA-8418: Wait until REST resources
are loaded when starting a Connect Worker.
URL: https://github.com/apache/kafka/pull/6840
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Connect System tests are not waiting for REST resources to be registered
> ------------------------------------------------------------------------
>
> Key: KAFKA-8418
> URL: https://issues.apache.org/jira/browse/KAFKA-8418
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.2.0
> Reporter: Oleksandr Diachenko
> Assignee: Oleksandr Diachenko
> Priority: Critical
> Fix For: 2.3.0
>
>
> I am getting an error while running Kafka tests:
> {code}
> Traceback (most recent call last): File
> "/home/jenkins/workspace/system-test-kafka_5.3.x/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.7.5-py2.7.egg/ducktape/tests/runner_client.py",
> line 132, in run data = self.run_test() File
> "/home/jenkins/workspace/system-test-kafka_5.3.x/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.7.5-py2.7.egg/ducktape/tests/runner_client.py",
> line 189, in run_test return self.test_context.function(self.test) File
> "/home/jenkins/workspace/system-test-kafka_5.3.x/kafka/tests/kafkatest/tests/connect/connect_rest_test.py",
> line 89, in test_rest_api assert set([connector_plugin['class'] for
> connector_plugin in self.cc.list_connector_plugins()]) ==
> \{self.FILE_SOURCE_CONNECTOR, self.FILE_SINK_CONNECTOR} File
> "/home/jenkins/workspace/system-test-kafka_5.3.x/kafka/tests/kafkatest/services/connect.py",
> line 218, in list_connector_plugins return self._rest('/connector-plugins/',
> node=node) File
> "/home/jenkins/workspace/system-test-kafka_5.3.x/kafka/tests/kafkatest/services/connect.py",
> line 234, in _rest raise ConnectRestError(resp.status_code, resp.text,
> resp.url) ConnectRestError
> {code}
> From the logs, I see two messages:
> {code}
> [2019-05-23 16:09:59,373] INFO REST server listening at
> http://172.31.39.205:8083/, advertising URL http://worker1:8083/
> (org.apache.kafka.connect.runtime.rest.RestServer)
> {code}
> and {code}
> [2019-05-23 16:10:00,738] INFO REST resources initialized; server is started
> and ready to handle requests
> (org.apache.kafka.connect.runtime.rest.RestServer)
> {code}
> it takes 1365 ms to actually load REST resources, but the test is waiting on
> a port to be listening.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
