[GitHub] [kafka] C0urante commented on pull request #9784: MINOR: Fix connector startup error logging

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org