bughelp wanted
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
kafka的支持cdc的,但是文档描述写的不支持
SeaTunnel Version
2.3.11
SeaTunnel Config
env {
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 10000
}
source {
MySQL-CDC {
base-url = "jdbc:mysql://host.docker.internal:3306/data_transfer_source"
username = "root"
password = "root"
table-names = ["data_transfer_source.users"]
startup.mode = "initial"
}
}
transform {
}
sink {
kafka {
topic = "seatunnel"
bootstrap.servers = "host.docker.internal:9092"
format = json
kafka.request.timeout.ms = 60000
kafka.config = {
acks = "all"
request.timeout.ms = 60000
buffer.memory = 33554432
}
}
}
Running Command
-
Error Exception
-
Zeta or Flink or Spark Version
No response
Java or Scala Version
No response
Screenshots
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct