Merge branch 'master' into patch-5

.asf.yaml

@@ -26,7 +26,7 @@ github:
  - event-streaming
  - event-sourcing
  - event-governance
- - event-routing
+ - event-connector
  - cloud-native
  - serverless
  - serverless-workflow
@@ -35,24 +35,41 @@ github:
  - cqrs
  - multi-runtime
  - microservice
- - state-management
  - hacktoberfest
- - hacktoberfest2022
  enabled_merge_buttons:
- squash:  true
- merge:  true
- rebase:  false
+ squash: true
+ merge: false
+ rebase: false
  protected_branches:
  master:
  required_status_checks:
  strict: true
  required_pull_request_reviews:
  dismiss_stale_reviews: true
- required_approving_review_count: 1
+ required_approving_review_count: 2
+ # Attempt to make the auto-generated github emails more easily readable in email clients.
+ custom_subjects:
+ new_pr: "[PR] {title} ({repository})"
+ close_pr: "Re: [PR] {title} ({repository})"
+ comment_pr: "Re: [PR] {title} ({repository})"
+ diffcomment: "Re: [PR] {title} ({repository})"
+ merge_pr: "Re: [PR] {title} ({repository})"
+ new_issue: "[I] {title} ({repository})"
+ comment_issue: "Re: [I] {title} ({repository})"
+ close_issue: "Re: [I] {title} ({repository})"
+ catchall: "[GH] {title} ({repository})"
+ new_discussion: "[D] {title} ({repository})"
+ edit_discussion: "Re: [D] {title} ({repository})"
+ close_discussion: "Re: [D] {title} ({repository})"
+ close_discussion_with_comment: "Re: [D] {title} ({repository})"
+ reopen_discussion: "Re: [D] {title} ({repository})"
+ new_comment_discussion: "Re: [D] {title} ({repository})"
+ edit_comment_discussion: "Re: [D] {title} ({repository})"
+ delete_comment_discussion: "Re: [D] {title} ({repository})"
 notifications:
- commits:  [email protected]
+ commits: [email protected]
  # Send all issue emails (new, closed, comments) to issues@
- issues:  [email protected]
+ issues: [email protected]
  # Send new/closed PR notifications to dev@
  pullrequests_status: [email protected]
  # Send individual PR comments/reviews to issues@

.dockerignore

@@ -0,0 +1,2 @@
+dist/
+build/

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -101,6 +101,14 @@ body:
  options:
  - label: Yes I am willing to submit a PR!
 
+ - type: checkboxes
+ attributes:
+ label: Code of Conduct
+ description: >
+ The Code of Conduct helps create a safe space for everyone. We require that everyone agrees to it..
+ options:
+ - label: I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) *
+
  - type: markdown
  attributes:
  value: "Thanks for completing our form!"

.github/ISSUE_TEMPLATE/documentation_related.yml

@@ -55,6 +55,14 @@ body:
  options:
  - label: Yes I am willing to submit a PR!
 
+ - type: checkboxes
+ attributes:
+ label: Code of Conduct
+ description: >
+ The Code of Conduct helps create a safe space for everyone. We require that everyone agrees to it..
+ options:
+ - label: I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) *
+
  - type: markdown
  attributes:
- value: "Thanks for completing our form!"
+ value: "Thanks for completing our form!"

.github/ISSUE_TEMPLATE/enhancement_request.yml

@@ -65,6 +65,13 @@ body:
  options:
  - label: Yes I am willing to submit a PR!
 
+ - type: checkboxes
+ attributes:
+ label: Code of Conduct
+ description: >
+ The Code of Conduct helps create a safe space for everyone. We require that everyone agrees to it..
+ options:
+ - label: I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) *
  - type: markdown
  attributes:
- value: "Thanks for completing our form!"
+ value: "Thanks for completing our form!"

.github/ISSUE_TEMPLATE/feature_request.yml

@@ -57,6 +57,14 @@ body:
  options:
  - label: Yes I am willing to submit a PR!
 
+ - type: checkboxes
+ attributes:
+ label: Code of Conduct
+ description: >
+ The Code of Conduct helps create a safe space for everyone. We require that everyone agrees to it..
+ options:
+ - label: I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) *
+
  - type: markdown
  attributes:
  value: "Thanks for completing our form!"

.github/ISSUE_TEMPLATE/unit_test.yml

@@ -41,7 +41,7 @@ body:
  attributes:
  label: Read the unit testing guidelines
  description: >
- Read the [unit testing guidelines](https://github.com/apache/eventmesh/blob/master/docs/en/contribute/02-write-unit-test.md) before writing unit test code.
+ Read the [unit testing guidelines](https://eventmesh.apache.org/community/contribute/write-unit-test) before writing unit test code.
  options:
  - label: >
  I have read.
@@ -83,4 +83,4 @@ body:
 
  - type: markdown
  attributes:
- value: "Thanks for completing our form!"
+ value: "Thanks for completing our form!"

.github/workflows/build.yaml

@@ -0,0 +1,40 @@
+#
+# 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:https://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.
+#
+name: Build
+on:
+ push:
+ branches:
+ - master
+
+jobs:
+ docker:
+ runs-on: ubuntu-latest
+ steps:
+ - name: Login to DockerHub
+ uses: docker/login-action@v2
+ with:
+ username: ${{ secrets.DOCKERHUB_USERNAME }}
+ password: ${{ secrets.DOCKERHUB_PASSWORD }}
+ - name: Build and push
+ uses: docker/build-push-action@v3
+ with:
+ push: true
+ tags: eventmesh/eventmesh:latest
+ file: ./docker/Dockerfile
+ context: ./

.github/workflows/ci.yml

@@ -48,12 +48,6 @@ jobs:
  # queries: ./path/to/local/query, your-org/your-repo/queries@main
  languages: ${{ matrix.language }}
 
- - name: Set up JDK ${{ matrix.java }}
- uses: actions/setup-java@v3
- with:
- distribution: 'zulu'
- java-version: ${{ matrix.java }}
-
  - name: Cache Gradle packages
  uses: actions/cache@v3
  with:
@@ -63,9 +57,24 @@ jobs:
  key: ${{ runner.os }}-gradle-${{ hashFiles('**/*.gradle*', '**/gradle-wrapper.properties') }}
  restore-keys: ${{ runner.os }}-gradle-
 
+ - name: Set up JDK 11
+ uses: actions/setup-java@v3
+ with:
+ distribution: 'zulu'
+ java-version: 11
+
+ - name: GenerateGrammarSource
+ run: ./gradlew clean generateGrammarSource --parallel --daemon
+
+ - name: Set up JDK ${{ matrix.java }}
+ uses: actions/setup-java@v3
+ with:
+ distribution: 'zulu'
+ java-version: ${{ matrix.java }}
+
  # https://docs.gradle.org/current/userguide/performance.html
  - name: Build
- run: ./gradlew clean build jar dist jacocoTestReport --parallel --daemon
+ run: ./gradlew clean build jar dist jacocoTestReport -x spotlessJava -x generateGrammarSource --parallel --daemon
 
  - name: Install plugin
  run: ./gradlew installPlugin
@@ -91,4 +100,4 @@ jobs:
 
  - name: Check third party dependencies
  run: |
- ./gradlew clean jar dist -x test -x checkstyleMain -x javaDoc && ./gradlew installPlugin && ./gradlew tar && sh tools/dependency-check/check-dependencies.sh && echo "Thirty party dependencies check success"
+ ./gradlew clean jar dist -x spotlessJava -x test -x checkstyleMain -x javaDoc && ./gradlew installPlugin && ./gradlew tar && sh tools/dependency-check/check-dependencies.sh && echo "Thirty party dependencies check success"

.github/workflows/greetings.yml

@@ -26,7 +26,7 @@ jobs:
  name: Greeting
  runs-on: ubuntu-latest
  steps:
- - uses: actions/first-interaction@v1
+ - uses: actions/first-interaction@v1.1.1
  with:
  repo-token: ${{ secrets.GITHUB_TOKEN }}
  issue-message: |
@@ -43,7 +43,7 @@ jobs:
 
  |WeChat Assistant|WeChat Public Account|Slack|
  |-|-|-|
- |<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-assistant.jpg?raw=true" width="128"/>|<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-official.jpg?raw=true" width="128"/>|[Join Slack Chat](https://join.slack.com/t/apacheeventmesh/shared_invite/zt-1ooav8slu-ijUI98MiEI501jhK1cabKQ)|
+ |<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-assistant.jpg?raw=true" width="128"/>|<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-official.jpg?raw=true" width="128"/>|[Join Slack Chat](https://join.slack.com/t/the-asf/shared_invite/zt-1y375qcox-UW1898e4kZE_pqrNsrBM2g)|
 
  Mailing Lists:
  | Name | Description |Subscribe |Unsubscribe|Archive
@@ -65,7 +65,7 @@ jobs:
 
  |WeChat Assistant|WeChat Public Account|Slack|
  |-|-|-|
- |<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-assistant.jpg?raw=true" width="128"/>|<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-official.jpg?raw=true" width="128"/>|[Join Slack Chat](https://join.slack.com/t/apacheeventmesh/shared_invite/zt-1ooav8slu-ijUI98MiEI501jhK1cabKQ)|
+ |<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-assistant.jpg?raw=true" width="128"/>|<img src="https://github.com/apache/eventmesh/blob/master/resources/wechat-official.jpg?raw=true" width="128"/>|[Join Slack Chat](https://join.slack.com/t/the-asf/shared_invite/zt-1y375qcox-UW1898e4kZE_pqrNsrBM2g)|
 
  Mailing Lists:
  | Name | Description |Subscribe |Unsubscribe|Archive

.gitignore

@@ -11,6 +11,7 @@ logs
 *.log
 *.log.*
 .idea
+!/.idea/icon.png
 build
 .classpath
 .project
@@ -30,3 +31,24 @@ h2/db.mv.db
 all-dependencies.txt
 self-modules.txt
 third-party-dependencies.txt
+
+# github codespaces or visual studio
+.vscode
+[Dd]ebug/
+[Dd]ebugPublic/
+[Rr]elease/
+[Rr]eleases/
+x64/
+x86/
+[Ww][Ii][Nn]32/
+[Aa][Rr][Mm]/
+[Aa][Rr][Mm]64/
+bld/
+[Bb]in/
+[Oo]bj/
+[Ll]og/
+[Ll]ogs/
+**/org/apache/eventmesh/connector/jdbc/antlr4/autogeneration/*
+
+#rust
+Cargo.lock

.licenserc.yaml

@@ -27,6 +27,7 @@ header:
  - '.gitmodules'
  - '**/.gitkeep'
  - '**/.gitignore'
+ - '**/.dockerignore'
  - '**/*.md'
  - '**/*.json'
  - '**/*.ftl'

README.md

@@ -11,7 +11,8 @@
 
 [![License](https://img.shields.io/github/license/apache/eventmesh?style=for-the-badge)](https://www.apache.org/licenses/LICENSE-2.0.html)
 [![GitHub Release](https://img.shields.io/github/v/release/apache/eventmesh?style=for-the-badge)](https://github.com/apache/eventmesh/releases)
-[![Slack Status](https://img.shields.io/badge/slack-join_chat-blue.svg?logo=slack&style=for-the-badge)](https://join.slack.com/t/apacheeventmesh/shared_invite/zt-1ooav8slu-ijUI98MiEI501jhK1cabKQ)
+[![Slack Status](https://img.shields.io/badge/slack-join_chat-blue.svg?logo=slack&style=for-the-badge)](https://join.slack.com/t/the-asf/shared_invite/zt-1y375qcox-UW1898e4kZE_pqrNsrBM2g)
+
 
 [📦 Documentation](https://eventmesh.apache.org/docs/introduction) |
 [📔 Examples](https://github.com/apache/eventmesh/tree/master/eventmesh-examples) |
@@ -26,7 +27,7 @@
 
 ### EventMesh Architecture
 
-![EventMesh Architecture](resources/eventmesh-architecture-3.png)
+![EventMesh Architecture](resources/eventmesh-architecture-4.png)
 
 ### EventMesh Dashboard
 ![EventMesh Dashboard](resources/dashboard.png)
@@ -36,9 +37,9 @@
 Apache EventMesh has a vast amount of features to help users achieve their goals. Let us share with you some of the key features EventMesh has to offer:
 
 - Built around the [CloudEvents](https://cloudevents.io) specification.
-- Rapidty extendsible interconnector layer such as the source or sink of Saas, CloudService, and Database etc.
-- Rapidty extendsible storage layer such as [Apache RocketMQ](https://rocketmq.apache.org), [Apache Kafka](https://kafka.apache.org), [Apache Pulsar](https://pulsar.apache.org), [RabbitMQ](https://rabbitmq.com), [Redis](https://redis.io), [Pravega](https://cncf.pravega.io), and [RDMS](https://en.wikipedia.org/wiki/Relational_database)(in progress) using [JDBC](https://en.wikipedia.org/wiki/Java_Database_Connectivity).
-- Rapidty extendsible controller such as [Consul](https://consulproject.org/en/), [Nacos](https://nacos.io), [ETCD](https://etcd.io) and [Zookeeper](https://zookeeper.apache.org/).
+- Rapidty extendsible interconnector layer [connectors](https://github.com/apache/eventmesh/tree/master/eventmesh-connectors) using [openConnect](https://github.com/apache/eventmesh/tree/master/eventmesh-openconnect) such as the source or sink of Saas, CloudService, and Database etc.
+- Rapidty extendsible storage layer such as [Apache RocketMQ](https://rocketmq.apache.org), [Apache Kafka](https://kafka.apache.org), [Apache Pulsar](https://pulsar.apache.org), [RabbitMQ](https://rabbitmq.com), [Redis](https://redis.io).
+- Rapidty extendsible meta such as [Consul](https://consulproject.org/en/), [Nacos](https://nacos.io), [ETCD](https://etcd.io) and [Zookeeper](https://zookeeper.apache.org/).
 - Guaranteed at-least-once delivery.
 - Deliver events between multiple EventMesh deployments.
 - Event schema management by catalog service.
@@ -50,7 +51,7 @@ Apache EventMesh has a vast amount of features to help users achieve their goals
 ## Roadmap
 Please go to the [roadmap](https://eventmesh.apache.org/docs/roadmap) to get the release history and new features of Apache EventMesh.
 
-## Community
+## Subprojects
 - [EventMesh-site](https://github.com/apache/eventmesh-site): Apache official website resources for EventMesh.
 - [EventMesh-workflow](https://github.com/apache/eventmesh-workflow): Serverless workflow runtime for event Orchestration on EventMesh.
 - [EventMesh-dashboard](https://github.com/apache/eventmesh-dashboard): Operation and maintenance console of EventMesh.
@@ -107,11 +108,11 @@ Apache EventMesh is licensed under the [Apache License, Version 2.0](http:https://www.
 
 |WeChat Assistant|WeChat Public Account|Slack|
 |-|-|-|
-|<img src="resources/wechat-assistant.jpg" width="128"/>|<img src="resources/wechat-official.jpg" width="128"/>|[Join Slack Chat](https://join.slack.com/t/apacheeventmesh/shared_invite/zt-1ooav8slu-ijUI98MiEI501jhK1cabKQ)|
+|<img src="resources/wechat-assistant.jpg" width="128"/>|<img src="resources/wechat-official.jpg" width="128"/>|[Join Slack Chat](https://join.slack.com/t/the-asf/shared_invite/zt-1y375qcox-UW1898e4kZE_pqrNsrBM2g)(Please open an issue if this link is expired)|
 
-bi-weekly meeting : [#Tencent meeting](https://meeting.tencent.com/dm/wes6Erb9ioVV) : 346-6926-0133
+Bi-weekly meeting : [#Tencent meeting](https://meeting.tencent.com/dm/wes6Erb9ioVV) : 346-6926-0133
 
-bi-weekly meeting record : [bilibili](https://space.bilibili.com/1057662180)
+Bi-weekly meeting record : [bilibili](https://space.bilibili.com/1057662180)
 
 ### Mailing List