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

Jump to bottom

ticdc: add more protocol in ticdc sink config #4691

Merged
merged 2 commits into from
Oct 15, 2020
Merged

ticdc: add more protocol in ticdc sink config #4691

Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
5d84be5
ticdc: add more protocol in ticdc sink config
amyangfei Oct 15, 2020
ffa2e22
Apply suggestions from code review
TomShawn Oct 15, 2020
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
4 changes: 2 additions & 2 deletions ticdc/manage-ticdc.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ URI 中可配置的的参数如下：
| `partition-num` | 下游 Kafka partition 数量（可选，不能大于实际 partition 数量。如果不填会自动获取 partition 数量。） |
| `max-message-bytes` | 每次向 Kafka broker 发送消息的最大数据量（可选，默认值 `64MB`） |
| `replication-factor` | kafka 消息保存副本数（可选，默认值 `1`） |
| `protocol` | 输出到 kafka 消息协议，可选值有 `default`, `canal`（默认值为 `default`） |
| `protocol` | 输出到 kafka 消息协议，可选值有 `default`, `canal`, `avro`, `maxwell`（默认值为 `default`） |
TomShawn marked this conversation as resolved.
Show resolved Hide resolved
| `ca` | 连接下游 Kafka 实例所需的 CA 证书文件路径（可选） |
| `cert` | 连接下游 Kafka 实例所需的证书文件路径（可选） |
| `key` | 连接下游 Kafka 实例所需的证书密钥文件路径（可选） |
Expand Down Expand Up @@ -630,7 +630,7 @@ dispatchers = [
{matcher = ['test3.*', 'test4.*'], dispatcher = "rowid"},
]
# 对于 MQ 类的 Sink，可以指定消息的协议格式
# 目前支持 default 和 canal 两种协议。default 为 TiCDC Open Protocol
# 目前支持 default，canal，avro 和 maxwell 四种协议。default 为 TiCDC Open Protocol
TomShawn marked this conversation as resolved.
Show resolved Hide resolved
protocol = "default"

[cyclic-replication]
Expand Down