This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 6901b5b6b update architecture image (#3910)
add d2d156020 Add eventmesh-connector-api
add 208260c53 fix the license header
add b18b83a12 remove the unused import
add f5ec01f49 fix checkStyle error
add 9f3f835e3 Merge pull request #3807 from xwm1992/eventmesh-connector-api
add e81a1f425 [ISSUE #3913] Add Source Connector RocketMQ Module (#3914)
add 6254be879 Update RocketMQSourceWorker.java
add 49f799ce3 Update README.md
add 997cc907c Merge pull request #3915 from apache/eventmesh-connector
No new revisions were added by this update.
Summary of changes:
eventmesh-connectors/README.md | 5 +-
.../build.gradle | 0
.../eventmesh-connector-api}/build.gradle | 0
.../eventmesh-connector-api}/gradle.properties | 0
.../eventmesh/connector/api/config/Config.java | 8 +-
.../eventmesh/connector/api/config/SinkConfig.java | 8 +-
.../connector/api/config/SourceConfig.java | 8 +-
.../connector/api/connector/Connector.java | 25 ++--
.../connector/api/connector/SinkConnector.java | 16 +--
.../connector/api/connector/SourceConnector.java | 16 +--
.../connector/api/data/ConnectRecord.java | 132 ++++++++++++++++++
.../connector/api/data/DefaultKeyValue.java | 152 +++++++++++++++++++++
.../eventmesh/connector/api/data/KeyValue.java | 66 +++++++++
.../eventmesh/connector/api/data/RecordOffset.java | 62 +++++++++
.../connector/api/data/RecordPartition.java | 64 +++++++++
.../connector/api/data/RecordPosition.java | 57 ++++++++
.../apache/eventmesh/connector/api/sink/Sink.java | 15 +-
.../eventmesh/connector/api/source/Source.java | 15 +-
.../gradle.properties | 0
.../source-connector-rocketmq}/build.gradle | 22 +--
.../source-connector-rocketmq}/gradle.properties | 1 +
.../connector/rocketmq/EventMeshTestUtils.java | 113 +++++++++++++++
.../connector/rocketmq/RocketMQSourceWorker.java | 77 +++++++++++
.../source/connector/rocketmq}/UtilsConstants.java | 2 +-
.../rocketmq/config/RocketMQSourceConfig.java | 63 +++++++++
.../connector/RocketMQSourceConnector.java | 107 +++++++++++++++
settings.gradle | 2 +
27 files changed, 958 insertions(+), 78 deletions(-)
copy {eventmesh-metrics-plugin => eventmesh-connectors}/build.gradle (100%)
copy {eventmesh-admin =>
eventmesh-connectors/eventmesh-connector-api}/build.gradle (100%)
copy {eventmesh-admin =>
eventmesh-connectors/eventmesh-connector-api}/gradle.properties (100%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/config/Config.java
(80%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/config/SinkConfig.java
(80%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/config/SourceConfig.java
(80%)
copy
eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/storage/RabbitmqStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/connector/Connector.java
(64%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/connector/SinkConnector.java
(69%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/connector/SourceConnector.java
(68%)
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/ConnectRecord.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/DefaultKeyValue.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/KeyValue.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/RecordOffset.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/RecordPartition.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/RecordPosition.java
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/sink/Sink.java
(72%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/source/Source.java
(73%)
copy {eventmesh-admin => eventmesh-connectors}/gradle.properties (100%)
copy {eventmesh-storage-plugin/eventmesh-storage-rocketmq =>
eventmesh-connectors/source-connector-rocketmq}/build.gradle (71%)
copy {eventmesh-examples =>
eventmesh-connectors/source-connector-rocketmq}/gradle.properties (97%)
create mode 100644
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/EventMeshTestUtils.java
create mode 100644
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/RocketMQSourceWorker.java
copy {eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common =>
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq}/UtilsConstants.java
(97%)
create mode 100644
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/config/RocketMQSourceConfig.java
create mode 100644
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/connector/RocketMQSourceConnector.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
