I am trying out the the <https://pulsar.apache.org...
# general
m
I am trying out the the https://pulsar.apache.org/docs/3.1.x/io-debezium-source/#example-of-microsoft-sql to do cdc from sqlserver to pulsar. my config looks like:
Copy code
{
  "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:
Copy code
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.
Copy code
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