⭐️
DataHub
DataHub 接收器连接器
描述
一个使用向 DataHub 发送消息的接收器插件
关键特性
选项
| 名称 | 类型 | 必需 | 默认值 |
|---|---|---|---|
| endpoint | string | 是 | - |
| accessId | string | 是 | - |
| accessKey | string | 是 | - |
| project | string | 是 | - |
| topic | string | 是 | - |
| timeout | int | 是 | - |
| retryTimes | int | 是 | - |
| common-options | 否 | - |
endpoint [string]
您的DataHub端点以http开头
accessId [string]
您的DataHub accessId可以从阿里云访问哪个云
accessKey[string]
您的DataHub accessKey可以从阿里云访问哪个云
project [string]
您在阿里云中创建的DataHub项目
topic [string]
您的DataHub主题
timeout [int]
最大连接超时
retryTimes [int]
客户端放置记录失败时的最大重试次数
common options
接收器插件常用参数，详见 Sink Common Options
示例
sink {
DataHub {
endpoint="yourendpoint"
accessId="xxx"
accessKey="xxx"
project="projectname"
topic="topicname"
timeout=3000
retryTimes=3
}
}
变更日志
Change Log
| Change | Commit | Version |
|---|---|---|
| [improve] datahub sink options (#8744) | https://github.com/apache/seatunnel/commit/88f35bd70 | 2.3.10 |
| [Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03 | 2.3.9 |
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755) | https://github.com/apache/seatunnel/commit/8de740810 | 2.3.4 |
| [Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd60105 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab16656 | 2.3.1 |
| [Hotfix][OptionRule] Fix option rule about all connectors (#3592) | https://github.com/apache/seatunnel/commit/226dc6a11 | 2.3.0 |
| [Improve][Connector-V2][DataHub] Unified exception for DataHub sink connector & change package name of DataHub (#3446) | https://github.com/apache/seatunnel/commit/395635fa1 | 2.3.0 |
| [improve][connector] The Factory#factoryIdentifier must be consistent with PluginIdentifierInterface#getPluginName (#3328) | https://github.com/apache/seatunnel/commit/d9519d696 | 2.3.0 |
| [Improve][Connector-V2][DataHub] Add DataHub Sink Factory (#3323) | https://github.com/apache/seatunnel/commit/685978d06 | 2.3.0 |
| [#2606]Dependency management split (#2630) | https://github.com/apache/seatunnel/commit/fc047be69 | 2.2.0-beta |
| [Feature][Connector-V2]Support datahub sink (#2558) | https://github.com/apache/seatunnel/commit/43600a704 | 2.2.0-beta |