Hi,
I have a 3 node Kafka Cluster, I used JDBC Source as a source connector. However, I have encountered the error below:
[2022-10-03 14:38:55,514] ERROR Encountered an unrecoverable error while reading tables from the database (io.confluent.connect.jdbc.source.TableMonitorThread:224)
org.apache.kafka.connect.errors.ConnectException: The request for task reconfiguration has been rejected because this instance of the connector ‘orcl-bulk-source’ has already been shut down.
at org.apache.kafka.connect.runtime.HerderConnectorContext.requestTaskReconfiguration(HerderConnectorContext.java:43)
at org.apache.kafka.connect.runtime.WorkerConnector$WorkerConnectorContext.requestTaskReconfiguration(WorkerConnector.java:501)
at io.confluent.connect.jdbc.source.TableMonitorThread.run(TableMonitorThread.java:86)
[2022-10-03 14:38:55,514] ERROR WorkerConnector{id=orcl-bulk-source} Connector raised an error (org.apache.kafka.connect.runtime.WorkerConnector:506)
org.apache.kafka.connect.errors.ConnectException: Encountered an unrecoverable error while reading tables from the database
at io.confluent.connect.jdbc.source.TableMonitorThread.fail(TableMonitorThread.java:226)
at io.confluent.connect.jdbc.source.TableMonitorThread.run(TableMonitorThread.java:89)
Caused by: org.apache.kafka.connect.errors.ConnectException: The request for task reconfiguration has been rejected because this instance of the connector ‘orcl-bulk-source’ has already been shut down.
at org.apache.kafka.connect.runtime.HerderConnectorContext.requestTaskReconfiguration(HerderConnectorContext.java:43)
at org.apache.kafka.connect.runtime.WorkerConnector$WorkerConnectorContext.requestTaskReconfiguration(WorkerConnector.java:501)
at io.confluent.connect.jdbc.source.TableMonitorThread.run(TableMonitorThread.java:86)
[2022-10-03 14:38:55,515] WARN Connector orcl-bulk-source attempted to raise error after shutdown: (org.apache.kafka.connect.runtime.HerderConnectorContext:56)
org.apache.kafka.connect.errors.ConnectException: Encountered an unrecoverable error while reading tables from the database
at io.confluent.connect.jdbc.source.TableMonitorThread.fail(TableMonitorThread.java:226)
at io.confluent.connect.jdbc.source.TableMonitorThread.run(TableMonitorThread.java:89)
Caused by: org.apache.kafka.connect.errors.ConnectException: The request for task reconfiguration has been rejected because this instance of the connector ‘orcl-bulk-source’ has already been shut down.
at org.apache.kafka.connect.runtime.HerderConnectorContext.requestTaskReconfiguration(HerderConnectorContext.java:43)
at org.apache.kafka.connect.runtime.WorkerConnector$WorkerConnectorContext.requestTaskReconfiguration(WorkerConnector.java:501)
at io.confluent.connect.jdbc.source.TableMonitorThread.run(TableMonitorThread.java:86)
[2022-10-03 14:38:55,533] INFO Completed shutdown for WorkerConnector{id=orcl-bulk-source} (org.apache.kafka.connect.runtime.WorkerConnector:269)
Connector Configuration:
curl -i -X PUT http://localhost:8083/connectors/orcl-bulk-source/config
-H “Content-Type: application/json”
-d ‘{
“connector.class”: “io.confluent.connect.jdbc.JdbcSourceConnector”,
“tasks.max” : “2”,
“connection.url”: “jdbc:oracle:thin:@192.168.1.13:1521/ORCL”,
“connection.user”: “system”,
“connection.password”: “password”,
“mode”:“bulk”,
“topic.prefix”:“orcl-”,
“name” : “orcl-bulk-source”
}’
JDBC Driver: Zipped JDBC driver (ojdbc10.jar) and Companion Jars