rg.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector

[Kotesh Banoth]

rg.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches org.wushujames.connect.mysql.MySqlSourceConnector, available connectors are: org.apache.kafka.connect.tools.MockConnector, org.apache.kafka.connect.tools.VerifiableSourceConnector, org.apache.kafka.connect.sink.SinkConnector, org.apache.kafka.connect.tools.SchemaSourceConnector, org.apache.kafka.connect.file.FileStreamSinkConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.tools.MockSourceConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apache.kafka.connect.source.SourceConnector

        at org.apache.kafka.connect.runtime.ConnectorFactory.getConnectorClass(ConnectorFactory.java:84)

        at org.apache.kafka.connect.runtime.ConnectorFactory.newConnector(ConnectorFactory.java:38)

        at org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:160)

        at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.startConnector(StandaloneHerder.java:237)

        at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:159)

        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:96)

[2016-11-15 20:14:57,831] ERROR Failed to create job for kafka-mysql-connector/connect-mysql-source.properties (org.apache.kafka.connect.cli.ConnectStandalone:91)

[2016-11-15 20:14:57,831] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:102)

java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to start connector: mysql-source

        at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:80)

        at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:67)

        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:99)

Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to start connector: mysql-source

        at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:160)

        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:96)

[Damian Guy]

It looks like the connector is not on the classpath: http://docs.confluent.io/3.1.1/connect/userguide.html#installing-connector-plugins

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/f7eb1a99-4291-4f75-b39a-798a324b01b8%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.