没有合适的资源?快使用搜索试试~ 我知道了~
openconnect:用于消息传递,事件和流的OpenConnect规范
共29个文件
java:23个
xml:2个
png:1个
需积分: 10 1 下载量 76 浏览量
2021-05-24
09:21:21
上传
评论
收藏 116KB ZIP 举报
温馨提示
OpenMessaging Connect 介绍 OpenMessaging Connect是在数据源和数据目标之间进行连接的标准。 用户可以轻松地通过REST API创建带有配置的连接器实例。 连接器有两种类型:源连接器和接收器连接器。 源连接器用于从数据源(例如RDBMS)中提取数据。 数据被发送到相应的消息队列,并有望被一个或多个接收器连接器使用。 接收器连接器从队列接收消息,并加载到数据目标(例如,数据仓库)中。 开发人员应实现源连接器或接收器连接器接口以运行其特定任务。 通常,连接器依赖于具体的消息队列进行数据传输。 消息队列将源连接器与接收器连接器解耦。 同时,它提供诸如故障转移,速率控制和一对多数据传输等功能。某些消息队列(例如Kafka)提供捆绑的连接框架以及各种由官方或社区开发的连接器。 但是,这些框架缺乏互操作性,这意味着为Kafka开发的连接器未经修改就无法与Ra
资源推荐
资源详情
资源评论
收起资源包目录
openconnect-master.zip (29个子文件)
openconnect-master
.gitignore 140B
flow.png 90KB
LICENSE 11KB
pom.xml 5KB
README.md 2KB
connector
src
main
java
io
openmessaging
connector
api
data
Converter.java 1KB
DataEntry.java 4KB
SourceDataEntry.java 3KB
DataEntryBuilder.java 3KB
Schema.java 3KB
SinkDataEntry.java 2KB
EntryType.java 1KB
FieldType.java 1KB
Field.java 2KB
exception
ConnectException.java 2KB
DataConnectException.java 2KB
PositionStorageReader.java 1KB
ConnectorContext.java 2KB
Task.java 1KB
sink
SinkConnector.java 1KB
SinkTaskContext.java 2KB
SinkTask.java 2KB
TaskContext.java 1KB
common
QueueMetaData.java 2KB
source
SourceTask.java 2KB
SourceTaskContext.java 1KB
SourceConnector.java 1KB
Connector.java 2KB
pom.xml 1KB
共 29 条
- 1
资源评论
仰光的瑞哥
- 粉丝: 14
- 资源: 4623
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功