This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 920f67e68 split storage and connectors
new 232de35b7 Merge pull request #3350 from qqeasonchen/master
920f67e68 is described below
commit 920f67e68893fd11c4ab7b0f0f996d5c23de274f
Author: qqeasonchen <[email protected]>
AuthorDate: Mon Mar 6 16:38:31 2023 +0800
split storage and connectors
---
eventmesh-connectors/README | 1 +
.../build.gradle | 0
.../eventmesh-connector-api/build.gradle | 0
.../eventmesh-connector-api/gradle.properties | 0
.../org/apache/eventmesh/api/AbstractContext.java | 0
.../apache/eventmesh/api/AsyncConsumeContext.java | 0
.../org/apache/eventmesh/api/EventListener.java | 0
.../org/apache/eventmesh/api/EventMeshAction.java | 0
.../api/EventMeshAsyncConsumeContext.java | 0
.../java/org/apache/eventmesh/api/LifeCycle.java | 0
.../apache/eventmesh/api/RequestReplyCallback.java | 0
.../org/apache/eventmesh/api/SendCallback.java | 0
.../java/org/apache/eventmesh/api/SendResult.java | 0
.../java/org/apache/eventmesh/api/admin/Admin.java | 0
.../eventmesh/api/admin/TopicProperties.java | 0
.../api/connector/ConnectorResourceService.java | 0
.../apache/eventmesh/api/consumer/Consumer.java | 0
.../api/exception/ConnectorRuntimeException.java | 0
.../api/exception/OnExceptionContext.java | 0
.../api/factory/ConnectorPluginFactory.java | 0
.../apache/eventmesh/api/producer/Producer.java | 0
.../eventmesh-connector-kafka/build.gradle | 0
.../eventmesh-connector-kafka/gradle.properties | 0
.../connector/kafka/common/Constants.java | 0
.../connector/kafka/common/EventMeshConstants.java | 0
.../kafka/config/ClientConfiguration.java | 0
.../ConnectorResourceServiceKafkaImpl.java | 0
.../connector/kafka/consumer/ConsumerImpl.java | 0
.../kafka/consumer/KafkaConsumerImpl.java | 0
.../kafka/consumer/KafkaConsumerRunner.java | 0
.../kafka/producer/KafkaProducerImpl.java | 0
.../connector/kafka/producer/ProducerImpl.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/kafka-client.properties | 0
.../kafka/config/ClientConfigurationTest.java | 0
.../org.apache.io.openmessaging.producer.Producer | 0
.../src/test/resources/kafka-client.properties | 0
.../eventmesh-connector-knative/build.gradle | 0
.../eventmesh-connector-knative/gradle.properties | 0
.../knative/cloudevent/KnativeMessageFactory.java | 0
.../impl/KnativeBinaryMessageReader.java | 0
.../knative/cloudevent/impl/KnativeHeaders.java | 0
.../cloudevent/impl/KnativeMessageWriter.java | 0
.../knative/config/ClientConfiguration.java | 0
.../ConnectorResourceServiceKnativeImpl.java | 0
.../knative/consumer/DefaultConsumer.java | 0
.../knative/consumer/KnativeConsumerImpl.java | 0
.../knative/consumer/PullConsumerImpl.java | 0
.../connector/knative/domain/NonStandardKeys.java | 0
.../patch/EventMeshConsumeConcurrentlyContext.java | 0
.../patch/EventMeshConsumeConcurrentlyStatus.java | 0
.../EventMeshMessageListenerConcurrently.java | 0
.../knative/producer/AbstractProducer.java | 0
.../knative/producer/KnativeProducerImpl.java | 0
.../connector/knative/producer/ProducerImpl.java | 0
.../connector/knative/utils/CloudEventUtils.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/knative-client.properties | 0
.../knative/config/ClientConfigurationTest.java | 0
.../knative/consumer/KnativeConsumerImplTest.java | 0
.../knative/producer/KnativeProducerImplTest.java | 0
.../src/test/resources/knative-client.properties | 0
.../eventmesh-connector-pravega/README.md | 0
.../eventmesh-connector-pravega/build.gradle | 0
.../eventmesh-connector-pravega/gradle.properties | 0
.../pravega-connector.jpg | Bin
.../PravegaConnectorResourceServiceImpl.java | 0
.../connector/pravega/PravegaConsumerImpl.java | 0
.../connector/pravega/PravegaProducerImpl.java | 0
.../connector/pravega/client/PravegaClient.java | 0
.../pravega/client/PravegaCloudEventWriter.java | 0
.../connector/pravega/client/PravegaEvent.java | 0
.../connector/pravega/client/SubscribeTask.java | 0
.../pravega/config/PravegaConnectorConfig.java | 0
.../exception/PravegaConnectorException.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../main/resources/pravega-connector.properties | 0
.../pravega/client/PravegaClientTest.java | 0
.../pravega/config/PravegaConnectorConfigTest.java | 0
.../test/resources/pravega-connector.properties | 0
.../eventmesh-connector-pulsar/build.gradle | 0
.../eventmesh-connector-pulsar/gradle.properties | 0
.../pulsar/client/PulsarClientWrapper.java | 0
.../pulsar/config/ClientConfiguration.java | 0
.../ConnectorResourceServicePulsarImpl.java | 0
.../pulsar/consumer/PulsarConsumerImpl.java | 0
.../pulsar/producer/AbstractProducer.java | 0
.../connector/pulsar/producer/ProducerImpl.java | 0
.../pulsar/producer/PulsarProducerImpl.java | 0
.../connector/pulsar/utils/CloudEventUtils.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/pulsar-client.properties | 0
.../pulsar/config/ClientConfigurationTest.java | 0
.../src/test/resources/pulsar-client.properties | 0
.../eventmesh-connector-rabbitmq/build.gradle | 0
.../eventmesh-connector-rabbitmq/gradle.properties | 0
.../connector/rabbitmq/client/RabbitmqClient.java | 0
.../rabbitmq/client/RabbitmqConnectionFactory.java | 0
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 0
.../cloudevent/RabbitmqCloudEventWriter.java | 0
.../rabbitmq/config/ConfigurationHolder.java | 120 ++++++++++-----------
.../RabbitmqConnectorResourceService.java | 0
.../rabbitmq/consumer/RabbitmqConsumer.java | 0
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 0
.../exception/RabbitmqaConnectorException.java | 0
.../rabbitmq/producer/RabbitmqProducer.java | 0
.../connector/rabbitmq/utils/ByteArrayUtils.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/rabbitmq-client.properties | 0
.../rabbitmq/RabbitmqMockConnectionFactory.java | 0
.../connector/rabbitmq/RabbitmqServer.java | 0
.../cloudevent/RabbitmqCloudEventTest.java | 0
.../rabbitmq/config/ConfigurationHolderTest.java | 0
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 0
.../rabbitmq/producer/RabbitmqProducerTest.java | 0
.../src/test/resources/rabbitmq-client.properties | 0
.../eventmesh-connector-redis/build.gradle | 0
.../eventmesh-connector-redis/gradle.properties | 0
.../connector/redis/client/RedissonClient.java | 0
.../redis/cloudevent/CloudEventCodec.java | 0
.../connector/redis/config/RedisProperties.java | 0
.../connector/RedisConnectorResourceService.java | 0
.../connector/redis/consumer/RedisConsumer.java | 0
.../connector/redis/producer/RedisProducer.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/redis-client.properties | 0
.../connector/redis/AbstractRedisServer.java | 0
.../connector/redis/client/RedissonClientTest.java | 0
.../redis/config/RedisPropertiesTest.java | 0
.../connector/redis/connector/UnitTest.java | 0
.../redis/consumer/RedisConsumerTest.java | 0
.../redis/producer/RedisProducerTest.java | 0
.../src/test/resources/redis-client.properties | 0
.../eventmesh-connector-rocketmq/build.gradle | 0
.../eventmesh-connector-rocketmq/gradle.properties | 0
.../connector/rocketmq/admin/RocketMQAdmin.java | 0
.../rocketmq/admin/RocketMQAdminAdaptor.java | 0
.../connector/rocketmq/admin/command/Command.java | 0
.../cloudevent/RocketMQMessageFactory.java | 0
.../impl/RocketMQBinaryMessageReader.java | 0
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 0
.../cloudevent/impl/RocketMQMessageWriter.java | 0
.../rocketmq/common/EventMeshConstants.java | 0
.../connector/rocketmq/config/ClientConfig.java | 0
.../rocketmq/config/ClientConfiguration.java | 0
.../ConnectorResourceServiceRocketmqImpl.java | 0
.../rocketmq/consumer/PushConsumerImpl.java | 0
.../rocketmq/consumer/RocketMQConsumerImpl.java | 0
.../connector/rocketmq/domain/NonStandardKeys.java | 0
.../exception/RMQMessageFormatException.java | 0
.../rocketmq/exception/RMQTimeoutException.java | 0
.../patch/EventMeshConsumeConcurrentlyContext.java | 0
.../patch/EventMeshConsumeConcurrentlyStatus.java | 0
.../EventMeshMessageListenerConcurrently.java | 0
.../rocketmq/producer/AbstractProducer.java | 0
.../connector/rocketmq/producer/ProducerImpl.java | 0
.../rocketmq/producer/RocketMQProducerImpl.java | 0
.../connector/rocketmq/utils/BeanUtils.java | 0
.../connector/rocketmq/utils/CloudEventUtils.java | 0
.../connector/rocketmq/utils/OMSUtil.java | 0
.../ConsumeMessageConcurrentlyService.java | 0
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/rocketmq-client.properties | 0
.../rocketmq/config/ClientConfigurationTest.java | 0
.../producer/DefaultProducerImplTest.java | 0
.../rocketmq/consumer/PushConsumerImplTest.java | 0
.../apache/rocketmq/producer/ProducerImplTest.java | 0
.../rocketmq/promise/DefaultPromiseTest.java | 0
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 0
.../org.apache.io.openmessaging.producer.Producer | 0
.../src/test/resources/rocketmq-client.properties | 0
.../eventmesh-connector-standalone/build.gradle | 0
.../gradle.properties | 0
.../standalone/admin/StandaloneAdmin.java | 0
.../standalone/admin/StandaloneAdminAdaptor.java | 0
.../connector/standalone/broker/MessageQueue.java | 0
.../standalone/broker/StandaloneBroker.java | 0
.../standalone/broker/model/MessageEntity.java | 0
.../standalone/broker/model/TopicMetadata.java | 0
.../broker/task/HistoryMessageClearTask.java | 0
.../standalone/broker/task/SubScribeTask.java | 0
.../standalone/consumer/StandaloneConsumer.java | 0
.../consumer/StandaloneConsumerAdaptor.java | 0
.../standalone/producer/StandaloneProducer.java | 0
.../producer/StandaloneProducerAdaptor.java | 0
.../StandaloneConnectorResourceService.java | 0
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../standalone/broker/StandaloneBrokerTest.java | 0
.../gradle.properties | 0
207 files changed, 61 insertions(+), 60 deletions(-)
diff --git a/eventmesh-connectors/README b/eventmesh-connectors/README
new file mode 100644
index 000000000..91a51793a
--- /dev/null
+++ b/eventmesh-connectors/README
@@ -0,0 +1 @@
+source and sink connectors
diff --git a/eventmesh-connector-plugin/build.gradle
b/eventmesh-storage/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/build.gradle
rename to eventmesh-storage/build.gradle
diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/build.gradle
b/eventmesh-storage/eventmesh-connector-api/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-api/build.gradle
rename to eventmesh-storage/eventmesh-connector-api/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/gradle.properties
b/eventmesh-storage/eventmesh-connector-api/gradle.properties
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-api/gradle.properties
rename to eventmesh-storage/eventmesh-connector-api/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendResult.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendResult.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendResult.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendResult.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
b/eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
rename to
eventmesh-storage/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
diff --git a/eventmesh-connector-plugin/eventmesh-connector-kafka/build.gradle
b/eventmesh-storage/eventmesh-connector-kafka/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-kafka/build.gradle
rename to eventmesh-storage/eventmesh-connector-kafka/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/gradle.properties
b/eventmesh-storage/eventmesh-connector-kafka/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/gradle.properties
rename to eventmesh-storage/eventmesh-connector-kafka/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/EventMeshConstants.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/EventMeshConstants.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/EventMeshConstants.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/EventMeshConstants.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ClientConfiguration.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ClientConfiguration.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ClientConfiguration.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ClientConfiguration.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
b/eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/kafka-client.properties
b/eventmesh-storage/eventmesh-connector-kafka/src/main/resources/kafka-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/kafka-client.properties
rename to
eventmesh-storage/eventmesh-connector-kafka/src/main/resources/kafka-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka/config/ClientConfigurationTest.java
b/eventmesh-storage/eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka/config/ClientConfigurationTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka/config/ClientConfigurationTest.java
rename to
eventmesh-storage/eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka/config/ClientConfigurationTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
b/eventmesh-storage/eventmesh-connector-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/resources/kafka-client.properties
b/eventmesh-storage/eventmesh-connector-kafka/src/test/resources/kafka-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/resources/kafka-client.properties
rename to
eventmesh-storage/eventmesh-connector-kafka/src/test/resources/kafka-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/build.gradle
b/eventmesh-storage/eventmesh-connector-knative/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-knative/build.gradle
rename to eventmesh-storage/eventmesh-connector-knative/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/gradle.properties
b/eventmesh-storage/eventmesh-connector-knative/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/gradle.properties
rename to eventmesh-storage/eventmesh-connector-knative/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java
b/eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/knative-client.properties
b/eventmesh-storage/eventmesh-connector-knative/src/main/resources/knative-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/knative-client.properties
rename to
eventmesh-storage/eventmesh-connector-knative/src/main/resources/knative-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/config/ClientConfigurationTest.java
b/eventmesh-storage/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/config/ClientConfigurationTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/config/ClientConfigurationTest.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/config/ClientConfigurationTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java
b/eventmesh-storage/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
b/eventmesh-storage/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
rename to
eventmesh-storage/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-knative/src/test/resources/knative-client.properties
b/eventmesh-storage/eventmesh-connector-knative/src/test/resources/knative-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/resources/knative-client.properties
rename to
eventmesh-storage/eventmesh-connector-knative/src/test/resources/knative-client.properties
diff --git a/eventmesh-connector-plugin/eventmesh-connector-pravega/README.md
b/eventmesh-storage/eventmesh-connector-pravega/README.md
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-pravega/README.md
rename to eventmesh-storage/eventmesh-connector-pravega/README.md
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/build.gradle
b/eventmesh-storage/eventmesh-connector-pravega/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-pravega/build.gradle
rename to eventmesh-storage/eventmesh-connector-pravega/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/gradle.properties
b/eventmesh-storage/eventmesh-connector-pravega/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/gradle.properties
rename to eventmesh-storage/eventmesh-connector-pravega/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/pravega-connector.jpg
b/eventmesh-storage/eventmesh-connector-pravega/pravega-connector.jpg
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/pravega-connector.jpg
rename to eventmesh-storage/eventmesh-connector-pravega/pravega-connector.jpg
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
b/eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties
b/eventmesh-storage/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties
rename to
eventmesh-storage/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
b/eventmesh-storage/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
b/eventmesh-storage/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
rename to
eventmesh-storage/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties
b/eventmesh-storage/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties
rename to
eventmesh-storage/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties
diff --git a/eventmesh-connector-plugin/eventmesh-connector-pulsar/build.gradle
b/eventmesh-storage/eventmesh-connector-pulsar/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-pulsar/build.gradle
rename to eventmesh-storage/eventmesh-connector-pulsar/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/gradle.properties
b/eventmesh-storage/eventmesh-connector-pulsar/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/gradle.properties
rename to eventmesh-storage/eventmesh-connector-pulsar/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/client/PulsarClientWrapper.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/client/PulsarClientWrapper.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/client/PulsarClientWrapper.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/client/PulsarClientWrapper.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/consumer/PulsarConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/consumer/PulsarConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/consumer/PulsarConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/consumer/PulsarConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties
b/eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java
b/eventmesh-storage/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/test/resources/pulsar-client.properties
b/eventmesh-storage/eventmesh-connector-pulsar/src/test/resources/pulsar-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/test/resources/pulsar-client.properties
rename to
eventmesh-storage/eventmesh-connector-pulsar/src/test/resources/pulsar-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/build.gradle
b/eventmesh-storage/eventmesh-connector-rabbitmq/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-rabbitmq/build.gradle
rename to eventmesh-storage/eventmesh-connector-rabbitmq/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/gradle.properties
b/eventmesh-storage/eventmesh-connector-rabbitmq/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/gradle.properties
rename to eventmesh-storage/eventmesh-connector-rabbitmq/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
similarity index 96%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
index 3631b3082..2f46c5642 100644
---
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
+++
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
@@ -1,60 +1,60 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.eventmesh.connector.rabbitmq.config;
-
-import org.apache.eventmesh.common.config.Config;
-import org.apache.eventmesh.common.config.ConfigFiled;
-
-import com.rabbitmq.client.BuiltinExchangeType;
-
-import lombok.Data;
-
-@Data
-@Config(prefix = "eventMesh.server.rabbitmq", path =
"classPath://rabbitmq-client.properties")
-public class ConfigurationHolder {
-
- @ConfigFiled(field = "host")
- private String host;
-
- @ConfigFiled(field = "port")
- private int port;
-
- @ConfigFiled(field = "username")
- private String username;
-
- @ConfigFiled(field = "passwd")
- private String passwd;
-
- @ConfigFiled(field = "virtualHost")
- private String virtualHost;
-
- @ConfigFiled(field = "exchangeType")
- private BuiltinExchangeType exchangeType;
-
- @ConfigFiled(field = "exchangeName")
- private String exchangeName;
-
- @ConfigFiled(field = "routingKey")
- private String routingKey;
-
- @ConfigFiled(field = "queueName")
- private String queueName;
-
- @ConfigFiled(field = "autoAck")
- private boolean autoAck;
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.connector.rabbitmq.config;
+
+import org.apache.eventmesh.common.config.Config;
+import org.apache.eventmesh.common.config.ConfigFiled;
+
+import com.rabbitmq.client.BuiltinExchangeType;
+
+import lombok.Data;
+
+@Data
+@Config(prefix = "eventMesh.server.rabbitmq", path =
"classPath://rabbitmq-client.properties")
+public class ConfigurationHolder {
+
+ @ConfigFiled(field = "host")
+ private String host;
+
+ @ConfigFiled(field = "port")
+ private int port;
+
+ @ConfigFiled(field = "username")
+ private String username;
+
+ @ConfigFiled(field = "passwd")
+ private String passwd;
+
+ @ConfigFiled(field = "virtualHost")
+ private String virtualHost;
+
+ @ConfigFiled(field = "exchangeType")
+ private BuiltinExchangeType exchangeType;
+
+ @ConfigFiled(field = "exchangeName")
+ private String exchangeName;
+
+ @ConfigFiled(field = "routingKey")
+ private String routingKey;
+
+ @ConfigFiled(field = "queueName")
+ private String queueName;
+
+ @ConfigFiled(field = "autoAck")
+ private boolean autoAck;
+}
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumer.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumer.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerHandler.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerHandler.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerHandler.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerHandler.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqaConnectorException.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqaConnectorException.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqaConnectorException.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqaConnectorException.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducer.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducer.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/rabbitmq-client.properties
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/rabbitmq-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/rabbitmq-client.properties
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/rabbitmq-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqMockConnectionFactory.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqMockConnectionFactory.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqMockConnectionFactory.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqMockConnectionFactory.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqServer.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqServer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqServer.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqServer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolderTest.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolderTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolderTest.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolderTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducerTest.java
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducerTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducerTest.java
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducerTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/resources/rabbitmq-client.properties
b/eventmesh-storage/eventmesh-connector-rabbitmq/src/test/resources/rabbitmq-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/resources/rabbitmq-client.properties
rename to
eventmesh-storage/eventmesh-connector-rabbitmq/src/test/resources/rabbitmq-client.properties
diff --git a/eventmesh-connector-plugin/eventmesh-connector-redis/build.gradle
b/eventmesh-storage/eventmesh-connector-redis/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-redis/build.gradle
rename to eventmesh-storage/eventmesh-connector-redis/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/gradle.properties
b/eventmesh-storage/eventmesh-connector-redis/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/gradle.properties
rename to eventmesh-storage/eventmesh-connector-redis/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
b/eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
b/eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
b/eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
b/eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
b/eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
b/eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/redis-client.properties
b/eventmesh-storage/eventmesh-connector-redis/src/main/resources/redis-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/redis-client.properties
rename to
eventmesh-storage/eventmesh-connector-redis/src/main/resources/redis-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
b/eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
b/eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
b/eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
b/eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
b/eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
b/eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-redis/src/test/resources/redis-client.properties
b/eventmesh-storage/eventmesh-connector-redis/src/test/resources/redis-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/resources/redis-client.properties
rename to
eventmesh-storage/eventmesh-connector-redis/src/test/resources/redis-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/build.gradle
b/eventmesh-storage/eventmesh-connector-rocketmq/build.gradle
similarity index 100%
rename from eventmesh-connector-plugin/eventmesh-connector-rocketmq/build.gradle
rename to eventmesh-storage/eventmesh-connector-rocketmq/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties
b/eventmesh-storage/eventmesh-connector-rocketmq/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties
rename to eventmesh-storage/eventmesh-connector-rocketmq/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/rocketmq-client.properties
b/eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/rocketmq-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/rocketmq-client.properties
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/rocketmq-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfigurationTest.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfigurationTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfigurationTest.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfigurationTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/resources/rocketmq-client.properties
b/eventmesh-storage/eventmesh-connector-rocketmq/src/test/resources/rocketmq-client.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/resources/rocketmq-client.properties
rename to
eventmesh-storage/eventmesh-connector-rocketmq/src/test/resources/rocketmq-client.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/build.gradle
b/eventmesh-storage/eventmesh-connector-standalone/build.gradle
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/build.gradle
rename to eventmesh-storage/eventmesh-connector-standalone/build.gradle
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/gradle.properties
b/eventmesh-storage/eventmesh-connector-standalone/gradle.properties
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/gradle.properties
rename to eventmesh-storage/eventmesh-connector-standalone/gradle.properties
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
b/eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
b/eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
b/eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
b/eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
b/eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename to
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
b/eventmesh-storage/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
similarity index 100%
rename from
eventmesh-connector-plugin/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
rename to
eventmesh-storage/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
diff --git a/eventmesh-connector-plugin/gradle.properties
b/eventmesh-storage/gradle.properties
similarity index 100%
rename from eventmesh-connector-plugin/gradle.properties
rename to eventmesh-storage/gradle.properties
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
