Impl/port message metadata dispatcher prs

.github/workflows/ci-build-macos.yaml

@@ -20,12 +20,13 @@
 name: CI - Build - MacOS
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
 

.github/workflows/ci-cpp-build-centos7.yaml

@@ -20,17 +20,12 @@
 name: CI - CPP build on CentOS 7
 on:
   pull_request:
-    branches:
-      - master
-    paths:
-      - '.github/workflows/**'
-      - 'pulsar-client-cpp/**'
-  push:
     branches:
       - branch-*
     paths:
       - '.github/workflows/**'
       - 'pulsar-client-cpp/**'
+
 jobs:
 
   cpp-build-centos7:

.github/workflows/ci-cpp-build-windows.yaml

@@ -20,18 +20,16 @@
 name: CI - CPP build on Windows
 on:
   pull_request:
-    branches:
-      - master
-    paths:
-      - '.github/workflows/**'
-      - 'pulsar-client-cpp/**'
-  push:
     branches:
       - branch-*
     paths:
       - '.github/workflows/**'
       - 'pulsar-client-cpp/**'
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   VCPKG_FEATURE_FLAGS: manifests
 
@@ -46,26 +44,26 @@ jobs:
       matrix:
         include:
           - name: 'Windows x64'
-            os: windows-latest
+            os: windows-2022
             triplet: x64-windows
             vcpkg_dir: 'C:\vcpkg'
             suffix: 'windows-win64'
-            generator: 'Visual Studio 16 2019'
+            generator: 'Visual Studio 17 2022'
             arch: '-A x64'
           - name: 'Windows x86'
-            os: windows-latest
+            os: windows-2022
             triplet: x86-windows
             vcpkg_dir: 'C:\vcpkg'
             suffix: 'windows-win32'
-            generator: 'Visual Studio 16 2019'
+            generator: 'Visual Studio 17 2022'
             arch: '-A Win32'
 
     steps:
       - name: checkout
         uses: actions/checkout@v2
 
       - name: Detect changed files
-        id:   changes
+        id: changes
         uses: apache/pulsar-test-infra/paths-filter@master
         with:
           filters: .github/changes-filter.yaml

.github/workflows/ci-cpp.yaml

@@ -20,12 +20,13 @@
 name: CI - CPP, Python Tests
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
 

.github/workflows/ci-documentbot.yml → .github/workflows/ci-documentbot.yaml

@@ -17,33 +17,41 @@
 # under the License.
 #
 
-name: Auto Labeling
+name: Documentation Bot
 
 on:
   pull_request_target :
     types:
       - opened
       - edited
       - labeled
+      - unlabeled
 
-
-
-# A GitHub token created for a PR coming from a fork doesn't have
-# 'admin' or 'write' permission (which is required to add labels)
-# To avoid this issue, you can use the `scheduled` event and run
-# this action on a certain interval.And check the label about the
-# document.
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
 
 jobs:
-  labeling:
+  label:
     if: ${{ github.repository == 'apache/pulsar' }}
     permissions:
-      pull-requests: write 
+      pull-requests: write
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+      - name: Checkout action
+        uses: actions/checkout@v3
+        with:
+          repository: apache/pulsar-test-infra
+          ref: master
 
-      - uses: apache/pulsar-test-infra/doc-label-check@master
+      - name: Set up Go
+        uses: actions/setup-go@v3
         with:
-          github-token: ${{ secrets.GITHUB_TOKEN }}
-          label-pattern: '- \[(.*?)\] ?`(.+?)`' # matches '- [x] `label`'
+          go-version: 1.18
+
+      - name: Labeling
+        uses: ./docbot
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+          LABEL_WATCH_LIST: 'doc,doc-required,doc-not-needed,doc-complete'
+          LABEL_MISSING: 'doc-label-missing'

.github/workflows/ci-go-functions-style.yaml

@@ -20,18 +20,16 @@
 name: CI - Go Functions style check
 on:
   pull_request:
-    branches:
-      - master
-    paths:
-      - '.github/workflows/**'
-      - 'pulsar-function-go/**'
-  push:
     branches:
       - branch-*
     paths:
       - '.github/workflows/**'
       - 'pulsar-function-go/**'
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
 

.github/workflows/ci-go-functions-test.yaml

@@ -20,18 +20,16 @@
 name: CI - Go Functions Tests
 on:
   pull_request:
-    branches:
-      - master
-    paths:
-      - '.github/workflows/**'
-      - 'pulsar-function-go/**'
-  push:
     branches:
       - branch-*
     paths:
       - '.github/workflows/**'
       - 'pulsar-function-go/**'
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
 

.github/workflows/ci-integration-backwards-compatibility.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Backwards Compatibility
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-cli.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Cli
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-function.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Function & IO
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-messaging.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Messaging
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-process.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Process
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-pulsar-io-ora.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Pulsar-IO Oracle Source
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-pulsar-io.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Pulsar-IO Sinks and Sources
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-schema.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Schema
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-sql.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Sql
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Xmx768m -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-standalone.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Standalone
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/

.github/workflows/ci-integration-thread.yaml

@@ -20,12 +20,13 @@
 name: CI - Integration - Thread
 on:
   pull_request:
-    branches:
-      - master
-  push:
     branches:
       - branch-*
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 env:
   MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
   UBUNTU_MIRROR: http://azure.archive.ubuntu.com/ubuntu/