Uploaded image for project: 'AMQ Streams'
  1. AMQ Streams
  2. ENTMQST-5491

[QE] Fix Kafka STs connect distributed 500

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Done
    • Icon: Undefined Undefined
    • 2.6.0.GA
    • None
    • None
    • None
    • False
    • None
    • False

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

              morsak Maros Orsak
              morsak Maros Orsak
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved:

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0 minutes
                  0m
                  Logged:
                  Time Spent - 4 hours
                  4h