Hi all
Is there a potential issue with creating a connector using incrementing mode
where the timestamp.column.name has underscores?
If I change the mode to bulk I get a successful status and a new topic created.
e.g.
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
…
“mode”: “incrementing”,
"incrementing.column.name": "”,
"validate.non.null": "true",
“timestamp.column.name”: “dtl__capxtimestamp”,
…
Version of Confluent Kafka used is 5.0.0
{
"class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"type": "source",
"version": "5.0.0"
}
curl -k -X GET http://localhost:8083/ | jq '.'
{
"version": "2.0.0-cp1",
"commit": "4b1dd33f255ddd2f",
Error seen in status of connector
{
"state": "FAILED",
"trace": "java.lang.NullPointerException\n\tat
io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.createPreparedStatement(TimestampIncrementingTableQuerier.java:116)\n\tat
io.confluent.connect.jdbc.source.TableQuerier.getOrCreatePreparedStatement(TableQuerier.java:75)\n\tat
io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.getOrCreatePreparedStatement(TimestampIncrementingTableQuerier.java:60)\n\tat
io.confluent.connect.jdbc.source.TableQuerier.maybeStartQuery(TableQuerier.java:87)\n\tat
io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.maybeStartQuery(TimestampIncrementingTableQuerier.java:60)\n\tat
io.confluent.connect.jdbc.source.JdbcSourceTask.poll(JdbcSourceTask.java:292)\n\tat
org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:244)\n\tat
org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:220)\n\tat
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)\n\tat
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)\n\tat
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat
java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat
java.lang.Thread.run(Thread.java:748)\n",
"id": 0,
"worker_id": "connect:8083"
}
Database
Postgresql 8.4
Column name: dtl__capxtimestamp timestamp NOT NULL,
Cheers
Peter Birksmith
_____________________________________________________________________
The information transmitted in this message and its attachments (if any) is
intended
only for the person or entity to which it is addressed.
The message may contain confidential and/or privileged material. Any review,
retransmission, dissemination or other use of, or taking of any action in
reliance
upon this information, by persons or entities other than the intended recipient
is
prohibited.
If you have received this in error, please contact the sender and delete this
e-mail
and associated material from any computer.
The intended recipient of this e-mail may only use, reproduce, disclose or
distribute
the information contained in this e-mail and any attached files, with the
permission
of the sender.
This message has been scanned for viruses.
_____________________________________________________________________
