This is an automated email from the ASF dual-hosted git repository.
wqliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 68c8f238a [ISSUE #4262] Enhancement Request EventMeshCloudEventUtils
(#4337)
new d3a48c8c3 add offsetStorage model
new d14acd2dc update offsetStorage model
new 412133237 modify the offset management service
new 939db459a modify the nacos config management service
new 8ab400018 modify the configs
new 4a1241765 Merge branch 'master' of https://github.com/apache/eventmesh
into add-offsetStorage
new 4f612f1f1 fix ci check error
new 4eddf3624 fix ci check error
new 9621900b7 fix ci check error
new 50bbaec17 Merge pull request #4329 from xwm1992/add-offsetStorage
The 4377 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kafka/sink/connector/KafkaSinkConnector.java | 2 +-
.../source/connector/KafkaSourceConnector.java | 6 +-
.../openfunction/service/ConsumerService.java | 16 +-
.../openfunction/service/ProducerService.java | 2 +-
.../sink/connector/OpenFunctionSinkConnector.java | 2 +-
.../connector/OpenFunctionSourceConnector.java | 2 +-
.../pulsar/sink/connector/PulsarSinkConnector.java | 2 +-
.../source/connector/PulsarSourceConnector.java | 4 +-
.../redis/sink/connector/RedisSinkConnector.java | 2 +-
.../source/connector/RedisSourceConnector.java | 2 +-
.../eventmesh-connector-rocketmq/build.gradle | 2 +-
.../sink/connector/RocketMQSinkConnector.java | 2 +-
.../source/connector/RocketMQSourceConnector.java | 6 +-
.../src/main/resources/sink-config.yml | 2 +-
.../src/main/resources/source-config.yml | 11 +-
.../eventmesh-openconnect-java/build.gradle | 2 +
.../apache/eventmesh/openconnect/Application.java | 4 +-
.../apache/eventmesh/openconnect/SinkWorker.java | 3 +-
.../apache/eventmesh/openconnect/SourceWorker.java | 137 ++++++++++-
.../openconnect/api/config/SourceConfig.java | 4 +
.../openconnect/api/connector/Connector.java | 2 +-
.../eventmesh/openconnect/api/sink/Sink.java | 2 +-
.../eventmesh/openconnect/api/source/Source.java | 2 +-
.../build.gradle | 0
.../build.gradle | 6 +-
.../gradle.properties | 0
.../offsetmgmt/api/config/OffsetStorageConfig.java | 13 +-
.../offsetmgmt}/api/data/ConnectRecord.java | 2 +-
.../offsetmgmt}/api/data/DefaultKeyValue.java | 2 +-
.../openconnect/offsetmgmt}/api/data/KeyValue.java | 2 +-
.../offsetmgmt}/api/data/RecordOffset.java | 2 +-
.../api/data/RecordOffsetManagement.java | 270 +++++++++++++++++++++
.../offsetmgmt}/api/data/RecordPartition.java | 2 +-
.../offsetmgmt}/api/data/RecordPosition.java | 5 +-
.../api/storage/ConnectorRecordPartition.java} | 47 ++--
.../offsetmgmt/api/storage/KeyValueStore.java | 106 ++++++++
.../api/storage/MemoryBasedKeyValueStore.java | 81 +++++++
.../api/storage/OffsetManagementService.java | 92 +++++++
.../api/storage/OffsetStorageReader.java | 25 +-
.../api/storage/OffsetStorageReaderImpl.java | 57 +++++
.../api/storage/OffsetStorageWriter.java | 24 +-
.../api/storage/OffsetStorageWriterImpl.java | 172 +++++++++++++
.../build.gradle | 2 +-
.../gradle.properties | 0
.../offsetmgmt/nacos/NacosConfigService.java | 178 ++++++++++++++
....offsetmgmt.api.storage.OffsetManagementService | 3 +-
.../gradle.properties | 0
.../eventmesh/spi/EventMeshExtensionType.java | 2 +
settings.gradle | 3 +
49 files changed, 1208 insertions(+), 107 deletions(-)
copy eventmesh-openconnect/{eventmesh-openconnect-java =>
eventmesh-openconnect-offsetmgmt-plugin}/build.gradle (100%)
copy {eventmesh-metrics-plugin/eventmesh-metrics-api =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api}/build.gradle
(84%)
copy {eventmesh-admin =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api}/gradle.properties
(100%)
copy
eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/config/PulsarSinkConfig.java
=>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/config/OffsetStorageConfig.java
(77%)
rename
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt}/api/data/ConnectRecord.java
(98%)
rename
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt}/api/data/DefaultKeyValue.java
(98%)
rename
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt}/api/data/KeyValue.java
(96%)
rename
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt}/api/data/RecordOffset.java
(96%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffsetManagement.java
copy
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt}/api/data/RecordPartition.java
(96%)
rename
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt}/api/data/RecordPosition.java
(91%)
rename
eventmesh-openconnect/{eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/data/RecordPartition.java
=>
eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/ConnectorRecordPartition.java}
(53%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/KeyValueStore.java
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/MemoryBasedKeyValueStore.java
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetManagementService.java
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReader.java
(64%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageReaderImpl.java
copy
eventmesh-registry-plugin/eventmesh-registry-zookeeper/src/main/java/org/apache/eventmesh/registry/zookeeper/pojo/EventMeshInstance.java
=>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriter.java
(66%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriterImpl.java
copy {eventmesh-registry-plugin/eventmesh-registry-nacos =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos}/build.gradle
(89%)
copy {eventmesh-admin =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos}/gradle.properties
(100%)
create mode 100644
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/nacos/NacosConfigService.java
copy eventmesh-admin/eventmesh-admin-rocketmq/gradle.properties =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.openconnect.offsetmgmt.api.storage.OffsetManagementService
(91%)
copy {eventmesh-admin =>
eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin}/gradle.properties
(100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
