{"error_code":500,"message":"Failed to find any class that implements Connector and which name matches org.apache.kafka.connect.tools.VerifiableSourceConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorCheckpointConnector, name=\'org.apache.kafka.connect.mirror.MirrorCheckpointConnector\', version=\'3.6.0.redhat-00003\', encodedVersion=3.6.0.redhat-00003, type=source, typeName=\'source\', location=\'classpath\'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name=\'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector\', version=\'3.6.0.redhat-00003\', encodedVersion=3.6.0.redhat-00003, type=source, typeName=\'source\', location=\'classpath\'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector, name=\'org.apache.kafka.connect.mirror.MirrorSourceConnector\', version=\'3.6.0.redhat-00003\', encodedVersion=3.6.0.redhat-00003, type=source, typeName=\'source\', location=\'classpath\'}"}', 'http://ducker08:8083/connectors') Traceback (most recent call last): File "/usr/local/lib/python3.9/site-packages/ducktape/tests/runner_client.py", line 186, in _do_run data = self.run_test() File "/usr/local/lib/python3.9/site-packages/ducktape/tests/runner_client.py", line 246, in run_test return self.test_context.function(self.test) File "/usr/local/lib/python3.9/site-packages/ducktape/mark/_mark.py", line 433, in wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) File "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_distributed_test.py", line 428, in test_bounce self.source.start() File "/opt/kafka-dev/tests/kafkatest/services/connect.py", line 493, in start self.cc.create_connector({ File "/opt/kafka-dev/tests/kafkatest/services/connect.py", line 199, in create_connector return self._rest_with_retry('/connectors', create_request, node=node, method="POST", **kwargs) File "/opt/kafka-dev/tests/kafkatest/services/connect.py", line 275, in _rest_with_retry raise exception_to_throw File "/opt/kafka-dev/tests/kafkatest/services/connect.py", line 269, in _rest_with_retry return self._rest(path, body, node, method) File "/opt/kafka-dev/tests/kafkatest/services/connect.py", line 255, in _rest raise ConnectRestError(resp.status_code, resp.text, resp.url) kafkatest.services.connect.ConnectRestError: (500, '{"error_code":500,"message":"Failed to find any class that implements Connector and which name matches org.apache.kafka.connect.tools.VerifiableSourceConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorCheckpointConnector, name=\'org.apache.kafka.connect.mirror.MirrorCheckpointConnector\', version=\'3.6.0.redhat-00003\', encodedVersion=3.6.0.redhat-00003, type=source, typeName=\'source\', location=\'classpath\'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name=\'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector\', version=\'3.6.0.redhat-00003\', encodedVersion=3.6.0.redhat-00003, type=source, typeName=\'source\', location=\'classpath\'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector, name=\'org.apache.kafka.connect.mirror.MirrorSourceConnector\', version=\'3.6.0.redhat-00003\', encodedVersion=3.6.0.redhat-00003, type=source, typeName=\'source\', location=\'classpath\'}"}', 'http://ducker08:8083/connectors')
Due to [1] change, we had to do the following fix [2].
[1] - https://issues.apache.org/jira/browse/KAFKA-14759
[2] - https://gitlab.cee.redhat.com/strimzi/amq-streams-utils/-/merge_requests/118