{"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