javaHelper / Apache-Kafka-Series---KSQL-on-ksqlDB-for-Stream-Processing-

0 stars 0 forks source link

Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector #1

Open javaHelper opened 2 years ago

javaHelper commented 2 years ago

I am using Confluent Kafka community edition locally on mac machine.

ksql> CREATE SOURCE CONNECTOR `postgres-jdbc-source` WITH (
>   "connector.class"='io.confluent.connect.jdbc.JdbcSourceConnector',
>   "connection.url"='jdbc:postgresql://postgres:5432/postgres',
>   "mode"='incrementing',
>   "incrementing.column.name"='ref',
>   "table.whitelist"='carusers',
>   "connection.password"='postgres',
>   "connection.user"='postgres',
>   "topic.prefix"='db-',
>   "key"='username');

Getting below error

{
  "error_code" : 500,
  "message" : "Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector, available connectors are: PluginDesc{klass=class io.confluent.connect.replicator.ReplicatorSourceConnector, name='io.confluent.connect.replicator.ReplicatorSourceConnector', version='7.0.1', encodedVersion=7.0.1, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/kafka-connect-replicator/'}, 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='file:/Users/prats/confluent-7.0.1/share/java/kafka/'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='1', encodedVersion=1, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/kafka/'}, 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='file:/Users/prats/confluent-7.0.1/share/java/kafka/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector, name='org.apache.kafka.connect.tools.MockConnector', version='7.0.1-ce', encodedVersion=7.0.1-ce, type=connector, typeName='connector', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqtt/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector, name='org.apache.kafka.connect.tools.MockSinkConnector', version='7.0.1-ce', encodedVersion=7.0.1-ce, type=sink, typeName='sink', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqtt/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector, name='org.apache.kafka.connect.tools.MockSourceConnector', version='7.0.1-ce', encodedVersion=7.0.1-ce, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqtt/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector, name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='7.0.1-ce', encodedVersion=7.0.1-ce, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqtt/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector, name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='7.0.1-ce', encodedVersion=7.0.1-ce, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqtt/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector, name='org.apache.kafka.connect.tools.VerifiableSourceConnector', version='7.0.1-ce', encodedVersion=7.0.1-ce, type=source, typeName='source', location='file:/Users/prats/confluent-7.0.1/share/java/confluent-kafka-mqtt/'}"
} 
javaHelper commented 2 years ago
confluent version 
confluent - Confluent CLI

Version:     v1.40.0
Git Ref:     1c975456
Build Date:  2021-09-23T02:04:31Z
Go Version:  go1.16.3 (darwin/arm64)
Development: false

prateekashtikar@Prateeks-MacBook-Pro ksql-course-master % confluent local version
The local commands are intended for a single-node development environment only,
NOT for production usage. https://docs.confluent.io/current/cli/index.html

Confluent Platform: 7.0.1
javaHelper commented 2 years ago
confluent version 
confluent - Confluent CLI

Version:     v1.40.0
Git Ref:     1c975456
Build Date:  2021-09-23T02:04:31Z
Go Version:  go1.16.3 (darwin/arm64)
Development: false

prateekashtikar@Prateeks-MacBook-Pro ksql-course-master % confluent local version
The local commands are intended for a single-node development environment only,
NOT for production usage. https://docs.confluent.io/current/cli/index.html

Confluent Platform: 7.0.1