iamrsaravana commented on issue #817:
URL:
https://github.com/apache/camel-kafka-connector/issues/817#issuecomment-751325339
for this command **kubectl logs deployment.apps/my-connect-cluster-connect
-n kafka**
i am getting below error message:
2020-12-26 06:26:31,979 ERROR Uncaught exception in REST call to
/connectors/camelamqpsourceconnector/config
(org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper)
[qtp1240328647-22]
org.apache.kafka.connect.errors.ConnectException: Failed to find any class
that implements Connector and which name matches
org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector, available
connectors are: PluginDesc{klass=class
org.apache.camel.kafkaconnector.CamelSinkConnector,
name='org.apache.camel.kafkaconnector.CamelSinkConnector', version='0.6.1',
encodedVersion=0.6.1, type=sink, typeName='sink',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.CamelSourceConnector,
name='org.apache.camel.kafkaconnector.CamelSourceConnector', version='0.6.1',
encodedVersion=0.6.1, type=source, typeName='source',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.activemq.CamelActivemqSinkConnector,
name='org.apache.camel.kafkaconnector.activemq.CamelActivemqSinkConnector',
version='0.6.1', encodedVersion=0.6.1, type=sink, typeName='sink',
location='file:/opt/kafka/plugins/camel/'}, Plugi
nDesc{klass=class
org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConnector,
name='org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConnector',
version='0.6.1', encodedVersion=0.6.1, type=source, typeName='source',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.kafka.connect.file.FileStreamSinkConnector,
name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector,
name='org.apache.kafka.connect.file.FileStreamSourceConnector',
version='2.6.0', encodedVersion=2.6.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorCheckpointConnector,
name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{kl
ass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector,
name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector,
name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector,
name='org.apache.kafka.connect.tools.MockConnector', version='2.6.0',
encodedVersion=2.6.0, type=connector, typeName='connector',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.tools.MockSinkConnector,
name='org.apache.kafka.connect.tools.MockSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector,
name='org.apache.kafka.connect.tool
s.MockSourceConnector', version='2.6.0', encodedVersion=2.6.0, type=source,
typeName='source', location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.tools.SchemaSourceConnector,
name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector,
name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class
org.apache.kafka.connect.tools.VerifiableSourceConnector,
name='org.apache.kafka.connect.tools.VerifiableSourceConnector',
version='2.6.0', encodedVersion=2.6.0, type=source, typeName='source',
location='classpath'}
at
org.apache.kafka.connect.runtime.isolation.Plugins.connectorClass(Plugins.java:208)
at
org.apache.kafka.connect.runtime.isolation.Plugins.newConnector(Plugins.java:180)
at
org.apache.kafka.connect.runtime.AbstractHerder.getConnector(AbstractHerder.java:572)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:342)
at
org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$1(AbstractHerder.java:326)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-12-26 06:28:31,877 ERROR Uncaught exception in REST call to
/connectors/camelamqpsourceconnector/config
(org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper)
[qtp1240328647-22]
org.apache.kafka.connect.errors.ConnectException: Failed to find any class
that implements Connector and which name matches
org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector, available
connectors are: PluginDesc{klass=class
org.apache.camel.kafkaconnector.CamelSinkConnector,
name='org.apache.camel.kafkaconnector.CamelSinkConnector', version='0.6.1',
encodedVersion=0.6.1, type=sink, typeName='sink',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.CamelSourceConnector,
name='org.apache.camel.kafkaconnector.CamelSourceConnector', version='0.6.1',
encodedVersion=0.6.1, type=source, typeName='source',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.camel.kafkaconnector.activemq.CamelActivemqSinkConnector,
name='org.apache.camel.kafkaconnector.activemq.CamelActivemqSinkConnector',
version='0.6.1', encodedVersion=0.6.1, type=sink, typeName='sink',
location='file:/opt/kafka/plugins/camel/'}, Plugi
nDesc{klass=class
org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConnector,
name='org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConnector',
version='0.6.1', encodedVersion=0.6.1, type=source, typeName='source',
location='file:/opt/kafka/plugins/camel/'}, PluginDesc{klass=class
org.apache.kafka.connect.file.FileStreamSinkConnector,
name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector,
name='org.apache.kafka.connect.file.FileStreamSourceConnector',
version='2.6.0', encodedVersion=2.6.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorCheckpointConnector,
name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{kl
ass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector,
name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector,
name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='1',
encodedVersion=1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector,
name='org.apache.kafka.connect.tools.MockConnector', version='2.6.0',
encodedVersion=2.6.0, type=connector, typeName='connector',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.tools.MockSinkConnector,
name='org.apache.kafka.connect.tools.MockSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector,
name='org.apache.kafka.connect.tool
s.MockSourceConnector', version='2.6.0', encodedVersion=2.6.0, type=source,
typeName='source', location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.tools.SchemaSourceConnector,
name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector,
name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='2.6.0',
encodedVersion=2.6.0, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class
org.apache.kafka.connect.tools.VerifiableSourceConnector,
name='org.apache.kafka.connect.tools.VerifiableSourceConnector',
version='2.6.0', encodedVersion=2.6.0, type=source, typeName='source',
location='classpath'}
at
org.apache.kafka.connect.runtime.isolation.Plugins.connectorClass(Plugins.java:208)
at
org.apache.kafka.connect.runtime.isolation.Plugins.newConnector(Plugins.java:180)
at
org.apache.kafka.connect.runtime.AbstractHerder.getConnector(AbstractHerder.java:572)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:342)
at
org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$1(AbstractHerder.java:326)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
----------------------------------------------------------------
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:
[email protected]
