debezium/dbz#1691 Add Python example demonstrating Debezium Connect-mode

.github/PULL_REQUEST_TEMPLATE.md

@@ -1,10 +1,10 @@
-## Description
-<!--
-Thanks a lot for taking time to contribute to Debezium <3!
-
-Please provide a description of what your PR does. It is really helpful for people who would review your code.
--->
-
-## Checklist
-
+## Description
+<!--
+Thanks a lot for taking time to contribute to Debezium <3!
+
+Please provide a description of what your PR does. It is really helpful for people who would review your code.
+-->
+
+## Checklist
+
 - [ ] If the changes include a new example, I added it to the list of examples in the [README.md](https://github.com/debezium/debezium-examples/blob/main/README.md) file

.github/workflows/apache-pulsar-workflow.yml

@@ -1,26 +1,26 @@
-name: Build [apache-pulsar]
-
-on:
-  push:
-    paths:
-      - 'apache-pulsar/**'
-      - '.github/workflows/apache-pulsar-workflow.yml'
-  pull_request:
-    paths:
-      - 'apache-pulsar/**'
-      - '.github/workflows/apache-pulsar-workflow.yml'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v6
-      - name: Cache local Maven repository
-        uses: actions/cache@v4
-        with:
-          path: ~/.m2/repository
-          key: ${{ runner.os }}-maven-${{ hashFiles('apache-pulsar/**/pom.xml') }}
-          restore-keys: |
-            ${{ runner.os }}-maven-
-      - name: Check changes in [apache-pulsar] example
-        run: cd apache-pulsar && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+name: Build [apache-pulsar]
+
+on:
+  push:
+    paths:
+      - 'apache-pulsar/**'
+      - '.github/workflows/apache-pulsar-workflow.yml'
+  pull_request:
+    paths:
+      - 'apache-pulsar/**'
+      - '.github/workflows/apache-pulsar-workflow.yml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v6
+      - name: Cache local Maven repository
+        uses: actions/cache@v4
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('apache-pulsar/**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Check changes in [apache-pulsar] example
+        run: cd apache-pulsar && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120

.github/workflows/auditlog-workflow.yml

@@ -1,26 +1,26 @@
-name: Build [auditlog]
-
-on:
-  push:
-    paths:
-      - 'auditlog/**'
-      - '.github/workflows/auditlog-workflow.yml'
-  pull_request:
-    paths:
-      - 'auditlog/**'
-      - '.github/workflows/auditlog-workflow.yml'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v6
-      - name: Cache local Maven repository
-        uses: actions/cache@v4
-        with:
-          path: ~/.m2/repository
-          key: ${{ runner.os }}-maven-${{ hashFiles('auditlog/**/pom.xml') }}
-          restore-keys: |
-            ${{ runner.os }}-maven-
-      - name: Check changes in [auditlog] example
-        run: cd auditlog && mvn clean package -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+name: Build [auditlog]
+
+on:
+  push:
+    paths:
+      - 'auditlog/**'
+      - '.github/workflows/auditlog-workflow.yml'
+  pull_request:
+    paths:
+      - 'auditlog/**'
+      - '.github/workflows/auditlog-workflow.yml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v6
+      - name: Cache local Maven repository
+        uses: actions/cache@v4
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('auditlog/**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Check changes in [auditlog] example
+        run: cd auditlog && mvn clean package -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120

.github/workflows/cache-invalidation-workflow.yml

@@ -1,31 +1,31 @@
-name: Build [cache-invalidation]
-
-on:
-  push:
-    paths:
-      - 'cache-invalidation/**'
-      - '.github/workflows/cache-invalidation-workflow.yml'
-  pull_request:
-    paths:
-      - 'cache-invalidation/**'
-      - '.github/workflows/cache-invalidation-workflow.yml'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Set up Java
-        uses: actions/setup-java@v4
-        with:
-          distribution: "temurin"
-          java-version: 21
-      - uses: actions/checkout@v6
-      - name: Cache local Maven repository
-        uses: actions/cache@v4
-        with:
-          path: ~/.m2/repository
-          key: ${{ runner.os }}-maven-${{ hashFiles('cache-invalidation/**/pom.xml') }}
-          restore-keys: |
-            ${{ runner.os }}-maven-
-      - name: Check changes in [cache-invalidation] example
-        run: cd cache-invalidation && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+name: Build [cache-invalidation]
+
+on:
+  push:
+    paths:
+      - 'cache-invalidation/**'
+      - '.github/workflows/cache-invalidation-workflow.yml'
+  pull_request:
+    paths:
+      - 'cache-invalidation/**'
+      - '.github/workflows/cache-invalidation-workflow.yml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Set up Java
+        uses: actions/setup-java@v4
+        with:
+          distribution: "temurin"
+          java-version: 21
+      - uses: actions/checkout@v6
+      - name: Cache local Maven repository
+        uses: actions/cache@v4
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('cache-invalidation/**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Check changes in [cache-invalidation] example
+        run: cd cache-invalidation && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120

.github/workflows/camel-component.yml

@@ -1,31 +1,31 @@
-name: Build [camel-component]
-
-on:
-  push:
-    paths:
-      - 'camel-component/**'
-      - '.github/workflows/camel-component-workflow.yml'
-  pull_request:
-    paths:
-      - 'camel-component/**'
-      - '.github/workflows/camel-component-workflow.yml'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v6
-      - name: Set up Java 17
-        uses: actions/setup-java@v3
-        with:
-          distribution: 'temurin'
-          java-version: 17
-      - name: Cache local Maven repository
-        uses: actions/cache@v4
-        with:
-          path: ~/.m2/repository
-          key: ${{ runner.os }}-maven-${{ hashFiles('camel-component/**/pom.xml') }}
-          restore-keys: |
-            ${{ runner.os }}-maven-
-      - name: Check changes in [camel-component] example
-        run: cd camel-component && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+name: Build [camel-component]
+
+on:
+  push:
+    paths:
+      - 'camel-component/**'
+      - '.github/workflows/camel-component-workflow.yml'
+  pull_request:
+    paths:
+      - 'camel-component/**'
+      - '.github/workflows/camel-component-workflow.yml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v6
+      - name: Set up Java 17
+        uses: actions/setup-java@v3
+        with:
+          distribution: 'temurin'
+          java-version: 17
+      - name: Cache local Maven repository
+        uses: actions/cache@v4
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('camel-component/**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Check changes in [camel-component] example
+        run: cd camel-component && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120

.github/workflows/camel-kafka-connect.yml

@@ -1,26 +1,26 @@
-name: Build [camel-kafka-connect]
-
-on:
-  push:
-    paths:
-      - 'camel-kafka-connect/**'
-      - '.github/workflows/camel-kafka-connect-workflow.yml'
-  pull_request:
-    paths:
-      - 'camel-kafka-connect/**'
-      - '.github/workflows/camel-kafka-connect-workflow.yml'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v6
-      - name: Cache local Maven repository
-        uses: actions/cache@v4
-        with:
-          path: ~/.m2/repository
-          key: ${{ runner.os }}-maven-${{ hashFiles('camel-kafka-connect/**/pom.xml') }}
-          restore-keys: |
-            ${{ runner.os }}-maven-
-      - name: Check changes in [camel-kafka-connect] example
-        run: cd camel-kafka-connect && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+name: Build [camel-kafka-connect]
+
+on:
+  push:
+    paths:
+      - 'camel-kafka-connect/**'
+      - '.github/workflows/camel-kafka-connect-workflow.yml'
+  pull_request:
+    paths:
+      - 'camel-kafka-connect/**'
+      - '.github/workflows/camel-kafka-connect-workflow.yml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v6
+      - name: Cache local Maven repository
+        uses: actions/cache@v4
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('camel-kafka-connect/**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Check changes in [camel-kafka-connect] example
+        run: cd camel-kafka-connect && mvn clean install -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120

.github/workflows/cloudevents.yml

@@ -1,26 +1,26 @@
-name: Build [cloudevents]
-
-on:
-  push:
-    paths:
-      - 'cloudevents/**'
-      - '.github/workflows/cloudevents-workflow.yml'
-  pull_request:
-    paths:
-      - 'cloudevents/**'
-      - '.github/workflows/cloudevents-workflow.yml'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v6
-      - name: Cache local Maven repository
-        uses: actions/cache@v4
-        with:
-          path: ~/.m2/repository
-          key: ${{ runner.os }}-maven-${{ hashFiles('cloudevents/**/pom.xml') }}
-          restore-keys: |
-            ${{ runner.os }}-maven-
-      - name: Check changes in [cloudevents] example
-        run: cd cloudevents && mvn clean install -f avro-data-extractor/pom.xml -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+name: Build [cloudevents]
+
+on:
+  push:
+    paths:
+      - 'cloudevents/**'
+      - '.github/workflows/cloudevents-workflow.yml'
+  pull_request:
+    paths:
+      - 'cloudevents/**'
+      - '.github/workflows/cloudevents-workflow.yml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v6
+      - name: Cache local Maven repository
+        uses: actions/cache@v4
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('cloudevents/**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Check changes in [cloudevents] example
+        run: cd cloudevents && mvn clean install -f avro-data-extractor/pom.xml -B -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120

.github/workflows/commit-signoff-check.yml

@@ -1,17 +1,17 @@
-name: Commit Sign-off Check
-on:
-  # ATTENTION: See https://securitylab.github.com/research/github-actions-preventing-pwn-requests/
-  # re security implications of using this trigger; in particular, no code from PR branches must
-  # be executed in any flows triggered by it
-  - pull_request_target
-
-jobs:
-  # Checks that all commits contain sign-offs
-  # Will add/remove comments as necessary based on the current status of the pull request.
-  check-signed-commits:
-    name: Check signed commits
-    runs-on: ubuntu-latest
-    steps:
-      - uses: debezium/dbz/.github/actions/check-dco@main
-        with:
+name: Commit Sign-off Check
+on:
+  # ATTENTION: See https://securitylab.github.com/research/github-actions-preventing-pwn-requests/
+  # re security implications of using this trigger; in particular, no code from PR branches must
+  # be executed in any flows triggered by it
+  - pull_request_target
+
+jobs:
+  # Checks that all commits contain sign-offs
+  # Will add/remove comments as necessary based on the current status of the pull request.
+  check-signed-commits:
+    name: Check signed commits
+    runs-on: ubuntu-latest
+    steps:
+      - uses: debezium/dbz/.github/actions/check-dco@main
+        with:
           add-comments: "true"