Hi all,
I have been working on the JDBC sink connector to SSMS and its neither been reading the topic nor writing it to SQL database. But the connector is showing running successfully in SwaggerUI. I have been told to include schema information but the schema is set to false by producer. What can i do in this case.
Here is my config:
name": “jdbc_sinkconnector”,
“config”: {
“connector.class”: “io.confluent.connect.jdbc.JdbcSinkConnector”,
“tasks.max”: “3”,
“topics”: “my_new_topic”,
“connection.url”: “jdbc_sql”,
“connection.user”: “SSMS”,
“connection.password”: “mypassword”,
“insert.mode”: “UPSERT”,
“pk.mode”: “kafka”,
“pk.fields”: “EMPLID”,
“auto.create”: “true”,
“auto.evolve”: “true”,
“transforms”: “RenameField”,
“transforms.RenameField.type”: “org.apache.kafka.connect.transforms.ReplaceField$Value”,
“transforms.RenameField.renames”: “EMPLID:empl_id,NAME:empl_name,POSITION_NBR:empl_position_nbr”,
“table.name.format”: “kafka_CC”,
“consumer.override.auto.offset.reset”: “latest”
}
}