Fix for version 3.8

Author: Kawron

.github/workflows/ci_build_test.yaml

@@ -149,10 +149,6 @@ jobs:
             kafka_package: "kafka_2.12-3.9.0.tgz"
             confluent_major_version: "7.9"
             confluent_package_version: "7.9.2"
-          - kafka_version: "4.0.0"
-            kafka_package: "kafka_2.13-4.0.0.tgz"
-            confluent_major_version: "8.0"
-            confluent_package_version: "8.0.0"
     env:
       CI_SPLUNK_VERSION: "9.0.2"
       CI_SPLUNK_FILENAME: splunk-9.0.2-17e00c557dc1-Linux-x86_64.tgz

test/lib/eventproducer_connector_upgrade.py

@@ -35,10 +35,10 @@ 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 2>/dev/null"
+                                       + " | grep -e ':[[:digit:]]*:' | grep -v WARN | 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 2>/dev/null"
+                                       + " | grep -e ':[[:digit:]]*:' | grep -v WARN | 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)))