Michael Olawepo
01/16/2024, 9:43 PM{
"database.hostname": "mssql",
"database.port": "1433",
"database.user": "sa",
"database.password": "mssql1Ipw",
"database.dbname": "BikeStores",
"database.server.name": "mssql",
"snapshot.mode": "schema_only",
"topic.namespace": "public/default",
"task.class": "io.debezium.connector.sqlserver.SqlServerConnectorTask",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"typeClassName": "org.apache.pulsar.common.schema.KeyValue",
"database.history": "org.apache.pulsar.io.debezium.PulsarDatabaseHistory",
"database.tcpKeepAlive": "true",
"decimal.handling.mode": "double",
"database.history.pulsar.topic": "debezium-mssql-source-history-topic",
"database.history.pulsar.service.url": "<pulsar://127.0.0.1:6650>"
}
when I run like:
bin/pulsar-admin source localrun \
--archive ./connectors/pulsar-io-debezium-mssql-3.1.2.nar \
--name mssql \
--source-config-file debezium-sqlserver-source-config.yaml
I get the error in the terminal.
024-01-16T20:28:34,176+0000 [pulsar-client-io-1-3] INFO org.apache.pulsar.client.impl.ProducerImpl - [public/default/mssql-debezium-offset-topic] [standalone-0-10] Closed Producer
2024-01-16T20:28:34,178+0000 [pulsar-client-io-1-3] INFO org.apache.pulsar.client.impl.ConsumerImpl - [public/default/mssql-debezium-offset-topic] [reader-fb29bbd3bb] Closed consumer
2024-01-16T20:28:58,858+0000 [function-timer-thread-52-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/mssql Function Container is dead with following exception. Restarting.
org.apache.kafka.connect.errors.ConnectException: Error configuring an instance of SqlServerConnectorTask; check the logs for details
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:123) ~[?:?]
at org.apache.pulsar.io.kafka.connect.AbstractKafkaConnectSource.open(AbstractKafkaConnectSource.java:162) ~[?:?]
at org.apache.pulsar.io.kafka.connect.KafkaConnectSource.open(KafkaConnectSource.java:63) ~[?:?]
at org.apache.pulsar.io.debezium.DebeziumSource.open(DebeziumSource.java:114) ~[?:?]
at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupInput(JavaInstanceRunnable.java:868) ~[org.apache.pulsar-pulsar-functions-instance-3.1.2.jar:3.1.2]
at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:263) ~[org.apache.pulsar-pulsar-functions-instance-3.1.2.jar:3.1.2]
at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:300) ~[org.apache.pulsar-pulsar-functions-instance-3.1.2.jar:3.1.2]
at java.lang.Thread.run(Thread.java:840) ~[?:?]
2024-01-16T20:28:58,865+0000 [function-timer-thread-52-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Unloading JAR files for instanceId 0 functionId f692525c-9d69-4d0b-8604-968ec15481e5 namespace default
2024-01-16T20:28:58,868+0000 [function-timer-thread-52-1] INFO org.apache.pulsar.common.nar.FileUtils - Jar file ./connectors/pulsar-io-debezium-mssql-3.1.2.nar contains META-INF/bundled-dependencies, it may be a NAR file