I am using confluent and configuring the connector in distributed mode
using REST.
I am setting the connector parameters as follows - but the connector
params do not include anything like connection.jdbcproperties, so I
cannot set oracle.jdbc.timezoneAsRegion=false.
Appending it to the jdbc url doesn't help.
{
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:oracle:thin:@oracleserver.local:1521:ors_sid",
"connection.user": "ors_user",
"connection.password": "secret",
"mode": "timestamp",
"timestamp.column.name": "LASTRELEVANTMODIFICATION",
"validate.non.null": "false",
"schemas.enable": "false",
"topic.prefix": "ors-entries",
"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",
"query": "select ORDERID, REQUESTERID, CREATIONDATE, ORDERSYSTEM,
PID, SHIPPEDDATE, RESPONDERID, LASTRELEVANTMODIFICATION from ORS_ORDER",
"poll.interval.ms": "60000",
"fetch.size": "5000",
"batch.max.rows": "5000",
"table.poll.interval.ms": "60000",
"transforms": "createKey, insertSourceDetails, deleteCreateDate",
"transforms.createKey.type":
"org.apache.kafka.connect.transforms.ValueToKey",
"transforms.createKey.fields": "ORDERID",
"transforms.insertSourceDetails.type":
"org.apache.kafka.connect.transforms.InsertField$Value",
"transforms.insertSourceDetails.static.field": "source",
"transforms.insertSourceDetails.static.value": "ors",
"transforms.deleteCreateDate.type":
"org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.deleteCreateDate.blacklist": "LASTRELEVANTMODIFICATION"
}
Den 25-04-2018 kl. 18:30 skrev adrien ruffie:
Hi Niels,
for using Kafka Connect, you must to define your connection configuration file
under kafka_2.11-1.0.0/config
(2.11-1.0.0 is just a example of kafka version). In config directory you can create a
connector file like "mysql-connect.properties"
and specify required parameters into this file. Example of mysql config
connector:
name=source-mysql-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
task.max=2
connection.url=jdbc:mysql://localhost:3306/test?user=your_user&password=your_password
table.whitelist=login,students,company
poll.interval.ms=10000
incrementing.column.name=id
mode=incrementing
topic.prefix=mysql-jdbc-
Did you try to put it ?
Best regards,
Adrien
________________________________
De : Niels Ull Harremoes <u...@lundogbendsen.dk>
Envoyé : mercredi 25 avril 2018 18:19:54
À : users@kafka.apache.org
Objet : How do I specify jdbc connection porperites in kafka-jdbc-connector
Hi!
I am tying to use the confluent connector verson 4.0.1 to connect to
oracle and set up a jdbc source.
Apparently I need to set a jdbc connection property,
oracle.jdbc.timezoneAsRegion=false, when connecting to my oracle database.
But I cannot find out where to set it - it cannot be set in the jdbc url
as far as I can tell, and I can apparently only set connection.url,
connection.username and connection.password in the connector config?
Any suggestions?
--
Med venlig hilsen
Niels Ull Harremoës
---
Denne e-mail blev kontrolleret for virusser af Avast antivirussoftware.
https://www.avast.com/antivirus
--
Med venlig hilsen
Niels Ull Harremoës
