Fixed a bug in test_basic_operation where consume was not working properly

Author: pranavrth

.semaphore/semaphore.yml

@@ -8,7 +8,7 @@ execution_time_limit:
 global_job_config:
   env_vars:
     - name: LIBRDKAFKA_VERSION
-      value: v2.10.0-RC2
+      value: v2.10.0-RC3
   prologue:
     commands:
       - checkout
@@ -279,6 +279,8 @@ blocks:
           value: osx
         - name: ARCH
           value: arm64
+        - name: PYTHONFAULTHANDLER
+          value: "1"
       jobs:
         - name: Build
           commands:

tests/integration/admin/test_basic_operations.py

@@ -277,7 +277,8 @@ def consume_messages(group_id, num_messages=None):
                     print('Read all the required messages: exiting')
                     break
             except ConsumeError as e:
-                if msg is not None and e.code == KafkaError._PARTITION_EOF:
+                if e.code == KafkaError._PARTITION_EOF:
+                    msg = e.kafka_message
                     print('Reached end of %s [%d] at offset %d' % (
                           msg.topic(), msg.partition(), msg.offset()))
                     eof_reached[(msg.topic(), msg.partition())] = True