apache/seatunnel

sink kafka文档描述有误

Open

#9,531 opened on Jul 2, 2025

View on GitHub
 (3 comments) (0 reactions) (1 assignee)Java (6,897 stars) (1,432 forks)batch import
bughelp wanted

Description

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

Image

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

Contributor guide

sink kafka文档描述有误 · apache/seatunnel#9531 | Good First Issue