run schema-registry-start as root

Author: Kawron

.github/workflows/ci_build_test.yaml

@@ -35,7 +35,7 @@ jobs:
     needs:
       - workflow_approval
     steps:
-      - name:  Checkout
+      - name: Checkout
         uses: actions/checkout@v3
         with:
           ref: ${{github.event.pull_request.head.sha}}
@@ -245,7 +245,7 @@ jobs:
           cd /tmp && wget https://packages.confluent.io/archive/${{ matrix.confluent_major_version }}/confluent-community-${{ matrix.confluent_package_version }}.tar.gz
           sudo tar xzf confluent-community-${{ matrix.confluent_package_version }}.tar.gz
           cd confluent-${{ matrix.confluent_package_version }}
-          bin/schema-registry-start ./etc/schema-registry/schema-registry.properties &
+          sudo bin/schema-registry-start ./etc/schema-registry/schema-registry.properties &
 
       - name: Register the protobuf schema
         run: |
@@ -377,7 +377,7 @@ jobs:
           export PYTHONWARNINGS="ignore:Unverified HTTPS request"
           echo "Running functional tests....."
           python -m pytest --log-level=INFO
-        
+
       - uses: actions/upload-artifact@v4
         if: failure()
         with:

test/lib/eventproducer_connector_upgrade.py

@@ -35,8 +35,8 @@ def check_events_from_topic(target):
             class_name = "kafka.tools.GetOffsetShell"
         else:
             class_name = "org.apache.kafka.tools.GetOffsetShell"
-        output1 = subprocess.getoutput(f" echo $(/usr/local/kafka/bin/kafka-run-class.sh ${class_name} --broker-list 'localhost:9092' --topic kafka_connect_upgrade  --time -1 | grep -e ':[[:digit:]]*:' | awk -F  ':' '{sum += $3} END {print sum}')")
-        output2 = subprocess.getoutput(f"echo $(/usr/local/kafka/bin/kafka-run-class.sh ${class_name} --broker-list 'localhost:9092' --topic kafka_connect_upgrade --time -2 | grep -e ':[[:digit:]]*:' | awk -F  ':' '{sum += $3} END {print sum}')")
+        output1 = subprocess.getoutput(f"echo $(/usr/local/kafka/bin/kafka-run-class.sh {class_name} --broker-list 'localhost:9092' --topic kafka_connect_upgrade  --time -1 | grep -e ':[[:digit:]]*:' | awk -F  ':' '{sum += $3} END {print sum}')")
+        output2 = subprocess.getoutput(f"echo $(/usr/local/kafka/bin/kafka-run-class.sh {class_name} --broker-list 'localhost:9092' --topic kafka_connect_upgrade --time -2 | grep -e ':[[:digit:]]*:' | awk -F  ':' '{sum += $3} END {print sum}')")
         time.sleep(5)
         if (int(output1)-int(output2))==target:
             logger.info("Events in the topic :" + str(int(output1)-int(output2)))