Data fusion replication is unable to connect to mysql database

[tmdedge]

Hello,

I successfully managed to connect to my mysql db using the wrangler.
When I try to create a replication job from the very same database using the UI, I manually copy paste the host / port / username / password (since data fusion doesn't seem to offer an option to use the connection that you create though the interface), and everything I can do is observe that the replication accelerator is unable to connect to the database. 

"Maybe an issue due to ssl" I thought.

So, I forced the use of SSL to false (source.connector.database.usessl => false in the preferences), and tried to create my pipeline using the API, just like the doc says.

It's great, I was able to create my replication job and even to start it.

However, not much happens when it starts:

2024-10-16 14:59:50,971 - WARN [worker-DeltaWorker-0:i.c.d.a.DeltaWorker@330] - Encountered an error (Attempt:1). Events will be replayed from the last successful commit.

org.apache.kafka.connect.errors.ConnectException: Error reading MySQL variables: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.

at io.debezium.connector.mysql.MySqlJdbcContext.querySystemVariables(MySqlJdbcContext.java:344)

at io.debezium.connector.mysql.MySqlJdbcContext.readMySqlSystemVariables(MySqlJdbcContext.java:324)

at io.debezium.connector.mysql.MySqlTaskContext.<init>(MySqlTaskContext.java:79)

at io.debezium.connector.mysql.MySqlTaskContext.<init>(MySqlTaskContext.java:52)

at io.debezium.connector.mysql.MySqlConnectorTask.createAndStartTaskContext(MySqlConnectorTask.java:357)

at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:143)

at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:106)

at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:758)

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

at java.util.concurrent.FutureTask.run(FutureTask.java:266)

at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)

at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

at java.lang.Thread.run(Thread.java:750)

Caused by: com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failure.


Networking is definitely set up correctly since I am able to connect to the very same database from another part of the interface, any hints regarding how to handle that?