search

confluentinc / kafka-connect-jdbc

Kafka Connect connector for JDBC-compatible databases
Other
1.01k stars 953 forks source link

Please tell me the command to connect the source and sink connectors to postgresql #1371

Open Kjj1997 opened 7 months ago

Kjj1997 commented 7 months ago 
          For me also it worked only after adding AVRO converter in source properties as well as in sink properties.

Source.properties :

name=local-console-source6 connector.class=io.confluent.connect.jdbc.JdbcSourceConnector tasks.max=1 topic.prefix=e_ connection.url=jdbc:mysql://127.0.0.1:3306/test_db connection.user=user connection.password=** table.whitelist=employee_source mode=incrementing

incrementing.column.name=id value.converter.schema.registry.url=http://localhost:8081 key.converter.schema.registry.url=http://localhost:8081 key.converter=io.confluent.connect.avro.AvroConverter value.converter=io.confluent.connect.avro.AvroConverter

Sink.Properties:

name=local-console-sink8 connector.class=io.confluent.connect.jdbc.JdbcSinkConnector tasks.max=1 topics=e_employee_source connection.url=jdbc:mysql://127.0.0.1:3306/test_db2 connection.user=root connection.password=***** auto.create=true

value.converter.schema.registry.url=http://localhost:8081 key.converter.schema.registry.url=http://localhost:8081 key.converter=io.confluent.connect.avro.AvroConverter value.converter=io.confluent.connect.avro.AvroConverter

With JSON converter is it failing. Why we can't use JSON schema?

Originally posted by @Surbhi27946 in https://github.com/confluentinc/kafka-connect-jdbc/issues/946#issuecomment-719167318