Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

TiCDC: Add 3 kafka addresses and correct the names of parameters #14439

Merged
merged 6 commits into from
Feb 6, 2025
Merged

TiCDC: Add 3 kafka addresses and correct the names of parameters #14439

Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
d857fb3
Add 3 kafka addresses and correct the names of parameters
chenmin1992 Jul 7, 2023
4b6ce8a
Merge remote-tracking branch 'upstream/master' into pr/14439
hfxsd Feb 6, 2025
4e52c4c
Update ticdc/ticdc-sink-to-kafka.md
hfxsd Feb 6, 2025
54153c8
Update ticdc/ticdc-sink-to-kafka.md
hfxsd Feb 6, 2025
e34ab92
Update ticdc/ticdc-sink-to-kafka.md
hfxsd Feb 6, 2025
03415ed
Update ticdc/ticdc-sink-to-kafka.md
hfxsd Feb 6, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions ticdc/ticdc-sink-to-kafka.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,14 +14,14 @@ summary: 了解如何使用 TiCDC 将数据同步到 Kafka。
```shell
cdc cli changefeed create \
--server=http://10.0.10.25:8300 \
--sink-uri="kafka://127.0.0.1:9092/topic-name?protocol=canal-json&kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1" \
--sink-uri="kafka://127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094/topic-name?protocol=canal-json&kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1" \
--changefeed-id="simple-replication-task"
```

```shell
Create changefeed successfully!
ID: simple-replication-task
Info: {"sink-uri":"kafka://127.0.0.1:9092/topic-name?protocol=canal-json&kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1","opts":{},"create-time":"2023-11-28T22:04:08.103600025+08:00","start-ts":415241823337054209,"target-ts":0,"admin-job-type":0,"sort-engine":"unified","sort-dir":".","config":{"case-sensitive":false,"filter":{"rules":["*.*"],"ignore-txn-start-ts":null,"ddl-allow-list":null},"mounter":{"worker-num":16},"sink":{"dispatchers":null},"scheduler":{"type":"table-number","polling-time":-1}},"state":"normal","history":null,"error":null}
Info: {"sink-uri":"kafka://127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094/topic-name?protocol=canal-json&kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1","opts":{},"create-time":"2023-11-28T22:04:08.103600025+08:00","start-ts":415241823337054209,"target-ts":0,"admin-job-type":0,"sort-engine":"unified","sort-dir":".","config":{"case-sensitive":false,"filter":{"rules":["*.*"],"ignore-txn-start-ts":null,"ddl-allow-list":null},"mounter":{"worker-num":16},"sink":{"dispatchers":null},"scheduler":{"type":"table-number","polling-time":-1}},"state":"normal","history":null,"error":null}
```

- `--server`：TiCDC 集群中任意一个 TiCDC 服务器的地址。
Expand Down Expand Up @@ -70,8 +70,8 @@ URI 中可配置的的参数如下：

| 参数 | 描述 |
| :------------------ | :------------------------------------------------------------ |
| `127.0.0.1` | 下游 Kafka 对外提供服务的 IP。 |
| `9092` | 下游 Kafka 的连接端口。 |
| `host` | 下游 Kafka 对外提供服务的 IP。 |
| `port` | 下游 Kafka 的连接端口。 |
| `topic-name` | 变量，使用的 Kafka topic 名字。 |
| `protocol` | 输出到 Kafka 的消息协议。可选值有 [`canal-json`](/ticdc/ticdc-canal-json.md)、[`open-protocol`](/ticdc/ticdc-open-protocol.md)、[`avro`](/ticdc/ticdc-avro-protocol.md)、[`debezium`](/ticdc/ticdc-debezium.md) 和 [`simple`](/ticdc/ticdc-simple-protocol.md)。 |
| `kafka-version` | 下游 Kafka 版本号。该值需要与下游 Kafka 的实际版本保持一致。 |
Expand Down