search

justonedb / kafka-sink-pg-json

Kafka sink connector for streaming messages to PostgreSQL
MIT License
91 stars 31 forks source link

Failed to find any class that implements Connector and which name matches com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector #22

Open jackeylhm opened 4 years ago

jackeylhm commented 4 years ago

I tried to start standlone server using the following command $ sudo cd /opt/kafka-justonedb/kafka-sink-pg-json-1.0.2 $ sudo export CLASSPATH=/opt/software/share/confluent-hub-components/confluentinc-kafka-connect-jdbc/lib/:/opt/software/share/java/confluent-hub-client/:/usr/share/java/kafka-serde-tools/:/usr/share/java/kafka/:/usr/share/java/confluent-serializers/* $ sudo /usr/bin/connect-standalone justone-kafka-sink-pg-json-standalone.properties justone-kafka-sink-pg-json-connector.properties

I got this mesage. [2020-01-02 09:39:59,361] ERROR Failed to create job for justone-kafka-sink-pg-json-connector.properties (org.apache.kafka.connect.cli.ConnectStandalone:89) [2020-01-02 09:39:59,363] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:100) java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector available connectors are: org.apache.kafka.connect.source.SourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, io.confluent.connect.jdbc.JdbcSinkConnector, io.confluent.connect.jdbc.JdbcSourceConnector, io.confluent.connect.hdfs.HdfsSinkConnector, io.confluent.connect.hdfs.tools.SchemaSourceConnector, org.apache.kafka.connect.sink.SinkConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apache.kafka.connect.tools.MockSourceConnector, org.apache.kafka.connect.tools.VerifiableSourceConnector, org.apache.kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.tools.MockConnector, org.apache.kafka.connect.file.FileStreamSinkConnector 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:97) Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector available connectors are: org.apache.kafka.connect.source.SourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, io.confluent.connect.jdbc.JdbcSinkConnector, io.confluent.connect.jdbc.JdbcSourceConnector, io.confluent.connect.hdfs.HdfsSinkConnector, io.confluent.connect.hdfs.tools.SchemaSourceConnector, org.apache.kafka.connect.sink.SinkConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apache.kafka.connect.tools.MockSourceConnector, org.apache.kafka.connect.tools.VerifiableSourceConnector, org.apache.kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.tools.MockConnector, org.apache.kafka.connect.file.FileStreamSinkConnector at org.apache.kafka.connect.runtime.Worker.getConnectorClass(Worker.java:226) at org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:166) at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.startConnector(StandaloneHerder.java:250) at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:164) at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:94)

Please help ( attach with how I setup this and full error message )

Confluent_DataSink_Setup_PostgreSQL.txt