{
    "name": "next-error-msg",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "tasks.max": "1",
        "connection.url": "DB_DATA_SOURCE_URL",
        "connection.user": "DB_DATA_SOURCE_USERNAME",
        "connection.password": "DB_DATA_SOURCE_PASSWORD",
        "schema.pattern": "DB_DATA_SCHEMA_PATTERN",
        "mode": "timestamp",
        "query": "SELECT SEQ_I AS error_id, SEND_I AS scac , to_char(CREATE_TS,'YYYY-MM-DD-HH24.MI.SS.FF6') AS create_timestamp, CREATE_TS, MSG_T AS error_message FROM DB_ERROR_MEG",
        "timestamp.column.name": "CREATE_TS",
        "validate.non.null": false,
        "topic.prefix": "DB_ERROR_MSG_TOPIC_NAME"
    }
}