Google Git
Sign in
apache / eventmesh / ced061db1dba3e986e982032cfb5c24121524823 / . / eventmesh-connectors
tree: f0d4720b7a1c109ebdddf76a12bf877759da93be [path history] [tgz]
  1. eventmesh-connector-dingtalk/
  2. eventmesh-connector-feishu/
  3. eventmesh-connector-file/
  4. eventmesh-connector-jdbc/
  5. eventmesh-connector-kafka/
  6. eventmesh-connector-knative/
  7. eventmesh-connector-mongodb/
  8. eventmesh-connector-openfunction/
  9. eventmesh-connector-pravega/
  10. eventmesh-connector-prometheus/
  11. eventmesh-connector-pulsar/
  12. eventmesh-connector-rabbitmq/
  13. eventmesh-connector-redis/
  14. eventmesh-connector-rocketmq/
  15. eventmesh-connector-s3/
  16. eventmesh-connector-slack/
  17. eventmesh-connector-spring/
  18. eventmesh-connector-wechat/
  19. eventmesh-connector-wecom/
  20. build.gradle
  21. gradle.properties
  22. README.md
eventmesh-connectors/README.md

Connectors

Connector

A connector is a bridge that interacts with a specific external service or underlying data source (e.g., Databases) on behalf of user applications. A connector is either a Source or a Sink.

Source

A source connector obtains data from an underlying data producer, and delivers it to targets after original data has been transformed into CloudEvents. It doesn't limit the way how a source retrieves data. (e.g., A source may pull data from a message queue or act as an HTTP server waiting for data sent to it).

Sink

A sink connector receives CloudEvents and does some specific business logics. (e.g., A MySQL Sink extracts useful data from CloudEvents and writes them to a MySQL database). CloudEvents - A specification for describing event data in common formats to provide interoperability across services, platforms and systems.

Implements

Add a new connector by implementing the source/sink interface using :

eventmesh-openconnect-java

Connector Status

Connector NameTypeStatus
RocketMQSource✅
RocketMQSink✅
ChatGPTSource⬜
ChatGPTSink⬜
ClickHouseSource⬜
ClickHouseSink⬜
DingDingSource⬜
DingtalkSink✅
EmailSource⬜
EmailSink⬜
FeiShuSource⬜
FeiShuSink✅
FileSource✅
FileSink✅
GithubSource⬜
GithubSink⬜
HttpSource⬜
HttpSink⬜
JdbcSource⬜
JdbcSink✅
KafkaSource✅
KafkaSink✅
KnativeSource✅
KnativeSink✅
MongoDBSource✅
MongoDBSink✅
OpenFunctionSource✅
OpenFunctionSink✅
PravegaSource✅
PravegaSink✅
PromethuesSource✅
PromethuesSink⬜
PulsarSource✅
PulsarSink✅
RabbitmqSource✅
RabbitmqSink✅
RedisSource✅
RedisSink✅
S3FileSource⬜
S3FileSink✅
SlackSource⬜
SlackSink✅
SpringSource✅
SpringSink✅
WeComSource⬜
WeComSink✅
More connectors will be added...Source/SinkN/A