apache/seatunnel

sink kafka文档描述有误

Open

#9,531 opened on Jul 2, 2025

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

Repository metrics

Stars
 (6,897 stars)
PR merge metrics
 (Avg merge 13d 21h) (143 merged PRs in 30d)

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