skip to Main Content

How to configure kafka connect jdbc sink connector for postgresql with ssl postgres authentication?

I have a working jdbc sink connector configuration for postgres using username and password configuration: { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "connection.url": "jdbc:postgresql://localhost:5432/postgres", "connection.user": "postgres-user", "connection.password": "postgres-pw", "topics.regex": "my-topic", "transforms": "unwrap", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.drop.tombstones": "false", "key.converter": "org.apache.kafka.connect.json.JsonConverter", "key.converter.schemas.enable": "false", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter.schemas.enable": "false",…

VIEW QUESTION

Random mysql crash when closing a statement

I have the following code: Statement statement =createStatement(); try (java.sql.ResultSet resultset = statement.executeQuery()) { while (resultset.next()) { myObject.setProcessingDate(resultset.getDate(1)); myObject.set... } }finally { if (statement != null) { statement.close(); } } I know that statement object should be created in the…

VIEW QUESTION
Back To Top
Search