apache / apache/seatunnel

sink kafka文档描述有误

Open
#9,531 3 comments 0 reactions 1 assignee Claimed by @comi-zhang View on GitHub
bug help wanted
Dominant language
Java
Stars
9.7k
Forks
2.4k
Avg merge
3d 9h
Merged PRs (30d)
204

Description

### Search before asking

- [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.

### What happened

![Image](https://github.com/user-attachments/assets/7edb37ab-d7ed-43fe-af3d-f0b2c1b570b6)

kafka的支持cdc的,但是文档描述写的不支持

### SeaTunnel Version

2.3.11

### SeaTunnel Config

```conf
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

```shell
-
```

### Error Exception

```log
-
```

### 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

- [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.