ericsyh commented on pull request #14590:
URL: https://github.com/apache/pulsar/pull/14590#issuecomment-1061438778
@gaoran10 @nodece Pulsar and debezium-mysql uses `2.8.1`, the ERROR from
functions is like below:
```
13:59:00.824 [public/default/debezium-mysql-source-0] ERROR
org.apache.pulsar.functions.instance.JavaInstanceRunnable - Source open
produced uncaught exception:
java.lang.IllegalArgumentException: Pulsar service URL not provided.
at
org.apache.pulsar.io.debezium.DebeziumSource.open(DebeziumSource.java:84)
~[pulsar-io-debezium-core-2.8.1.jar:2.8.1]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupInput(JavaInstanceRunnable.java:735)
[org.apache.pulsar-pulsar-functions-instance-2.8.1.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:219)
[org.apache.pulsar-pulsar-functions-instance-2.8.1.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:243)
[org.apache.pulsar-pulsar-functions-instance-2.8.1.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292]
13:59:00.829 [public/default/debezium-mysql-source-0] ERROR
org.apache.pulsar.functions.instance.JavaInstanceRunnable -
[public/default/debezium-mysql-source:0] Uncaught exception in Java Instance
java.lang.IllegalArgumentException: Pulsar service URL not provided.
at
org.apache.pulsar.io.debezium.DebeziumSource.open(DebeziumSource.java:84) ~[?:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupInput(JavaInstanceRunnable.java:735)
~[org.apache.pulsar-pulsar-functions-instance-2.8.1.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:219)
~[org.apache.pulsar-pulsar-functions-instance-2.8.1.jar:?]
at
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:243)
[org.apache.pulsar-pulsar-functions-instance-2.8.1.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292]
```
The `mysql.yaml` config file is
```
tenant: "public"
namespace: "default"
name: "debezium-mysql-source"
topicName: "debezium-mysql-topic"
archive: "connectors/pulsar-io-debezium-mysql-2.8.1.nar"
parallelism: 1
configs:
## config for mysql, docker image: debezium/example-mysql:0.8
database.hostname: "x.x.x.x"
database.port: "3306"
database.user: "ericsyh"
database.password: "x.x.x.x.x.x"
database.server.id: "1840"
database.server.name: "streamnative"
database.whitelist: "pulsar"
database.history: "org.apache.pulsar.io.debezium.PulsarDatabaseHistory"
database.history.pulsar.topic: "history-topic"
database.history.pulsar.service.url: "pulsar://127.0.0.1:6650"
## KEY_CONVERTER_CLASS_CONFIG, VALUE_CONVERTER_CLASS_CONFIG
key.converter: "org.apache.kafka.connect.json.JsonConverter"
value.converter: "org.apache.kafka.connect.json.JsonConverter"
## OFFSET_STORAGE_TOPIC_CONFIG
offset.storage.topic: "offset-topic"
```
The status for the sources
```
{
"numInstances" : 1,
"numRunning" : 0,
"instances" : [ {
"instanceId" : 0,
"status" : {
"running" : false,
"error" : "UNAVAILABLE: io exception",
"numRestarts" : 0,
"numReceivedFromSource" : 0,
"numSystemExceptions" : 0,
"latestSystemExceptions" : [ ],
"numSourceExceptions" : 0,
"latestSourceExceptions" : [ ],
"numWritten" : 0,
"lastReceivedTime" : 0,
"workerId" : "standalone"
}
} ]
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
