C0urante commented on pull request #9784:
URL: https://github.com/apache/kafka/pull/9784#issuecomment-752650790
@chia7712 sure, here's an example:
```
[2020-12-30 09:56:35,481] ERROR [test-connector|worker] [Worker
clientId=connect-1, groupId=connect-cluster] Failed to start connector 'conn-1'
(org.apache.kafka.connect.runtime.distributed.DistributedHerder:599)
org.apache.kafka.connect.errors.ConnectException: Failed to start connector:
conn-1
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$startConnector$4(DistributedHerder.java:1298)
at
org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:294)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.startConnector(DistributedHerder.java:1322)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.processConnectorConfigUpdates(DistributedHerder.java:597)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:416)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:294)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to find
any class that implements Connector and which name matches not-found, available
connectors are: PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$BlockingConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$BlockingConnector',
version='0.0.0', encodedVersion=0.0.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$BlockingSinkConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$BlockingSinkConnector',
version='0.0.0', encodedVersion=0.0.0, type=sink, typeName='sink',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$BlockingSourceConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$BlockingSourceConnector',
version='0.0.0', encodedVersion=0.0.0, type=source, typeName=
'source', location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$ConfigBlockingConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$ConfigBlockingConnector',
version='0.0.0', encodedVersion=0.0.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$InitializeBlockingConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$InitializeBlockingConnector',
version='0.0.0', encodedVersion=0.0.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$TaskInitializeBlockingSinkConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$TaskInitializeBlockingSinkConnector',
version='0.0.0', encodedVersion=0.0.0, type=sink, typeName='sink',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.
BlockingConnectorTest$TaskInitializeBlockingSourceConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$TaskInitializeBlockingSourceConnector',
version='0.0.0', encodedVersion=0.0.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.BlockingConnectorTest$ValidateBlockingConnector,
name='org.apache.kafka.connect.integration.BlockingConnectorTest$ValidateBlockingConnector',
version='0.0.0', encodedVersion=0.0.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.ErrantRecordSinkConnector,
name='org.apache.kafka.connect.integration.ErrantRecordSinkConnector',
version='some great version', encodedVersion=some great version, type=sink,
typeName='sink', location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.MonitorableSinkConnector,
name='org.apache.kafka.connect.integration.MonitorableSinkConnector',
version='so
me great version', encodedVersion=some great version, type=sink,
typeName='sink', location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.integration.MonitorableSourceConnector,
name='org.apache.kafka.connect.integration.MonitorableSourceConnector',
version='an entirely different version', encodedVersion=an entirely different
version, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.runtime.TestSinkConnector,
name='org.apache.kafka.connect.runtime.TestSinkConnector', version='some great
version', encodedVersion=some great version, type=sink, typeName='sink',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.runtime.TestSourceConnector,
name='org.apache.kafka.connect.runtime.TestSourceConnector', version='an
entirely different version', encodedVersion=an entirely different version,
type=source, typeName='source', location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.runtime.Work
erTest$WorkerTestConnector,
name='org.apache.kafka.connect.runtime.WorkerTest$WorkerTestConnector',
version='1.0', encodedVersion=1.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.runtime.WorkerWithTopicCreationTest$WorkerTestConnector,
name='org.apache.kafka.connect.runtime.WorkerWithTopicCreationTest$WorkerTestConnector',
version='1.0', encodedVersion=1.0, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResourceTest$ConnectorPluginsResourceTestConnector,
name='org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResourceTest$ConnectorPluginsResourceTestConnector',
version='1.0', encodedVersion=1.0, type=connector, typeName='connector',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.tools.MockConnector,
name='org.apache.kafka.connect.tools.MockConnector', version='unknown',
encodedVersion=unknown,
type=connector, typeName='connector', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector,
name='org.apache.kafka.connect.tools.MockSinkConnector', version='unknown',
encodedVersion=unknown, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector,
name='org.apache.kafka.connect.tools.MockSourceConnector', version='unknown',
encodedVersion=unknown, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector,
name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='unknown',
encodedVersion=unknown, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector,
name='org.apache.kafka.connect.tools.VerifiableSinkConnector',
version='unknown', encodedVersion=unknown, type=source, typeName='source',
location='classpath'}, Plug
inDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector,
name='org.apache.kafka.connect.tools.VerifiableSourceConnector',
version='unknown', encodedVersion=unknown, 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.Worker.startConnector(Worker.java:275)
... 9 more
```
Thanks for the review 🙏
----------------------------------------------------------------
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
