-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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.
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: update pulsar sink #4294
Conversation
Signed-off-by: Neil Shen <overvenus@gmail.com>
Signed-off-by: Neil Shen <overvenus@gmail.com>
PTAL @TomShawn @amyangfei |
@amyangfei, @TomShawn, PTAL. |
@@ -111,64 +111,98 @@ Info: {"sink-uri":"mysql://root:123456@127.0.0.1:3306/","opts":{},"create-time": | |||
``` | |||
|
|||
- `--changefeed-id`: 同步任务的 ID,格式需要符合正则表达式 `^[a-zA-Z0-9]+(\-[a-zA-Z0-9]+)*$`。如果不指定该 ID,TiCDC 会自动生成一个 UUID(version 4 格式)作为 ID。 | |||
- `--sink-uri`: 同步任务下游的地址,需要按照以下格式进行配置,目前 scheme 支持 `mysql`/`tidb`/`kafka`。 | |||
- `--sink-uri`: 同步任务下游的地址,需要按照以下格式进行配置,目前 scheme 支持 `mysql`/`tidb`/`kafka`/`pulsar`。 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
mysql/tidb/pulsar 同样支持 mysql+ssl/tidb+ssl/pulsar+ssl,是否需要也在文档里写出
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
我觉得没必要,因为 SSL/TLS 开启与否在于 URI 中的参数,而不是 scheme。
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
那代码里 +ssl
的存在也没有意义了,现阶段 scheme 中的 +ssl
在代码里只是标识,不做检查
@overvenus, please update your pull request. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
@amyangfei,Thanks for your review. However, LGTM is restricted to Reviewers or higher roles.See the corresponding SIG page for more information. Related SIGs: docs(slack). |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Signed-off-by: ti-srebot <ti-srebot@pingcap.com>
cherry pick to release-4.0 in PR #4359 |
What is changed, added or deleted? (Required)
Update the Apache Pulsar sink configuration.
Which TiDB version(s) do your changes apply to? (Required)
What is the related PR or file link(s)?
Do your changes match any of the following descriptions?