#39 Fix empty threaded messages (#40)

* Handle empty messages in threaded consumer

* Update version.py

Author: robooo

src/ConfluentKafkaLibrary/consumer.py

@@ -361,10 +361,9 @@ def get_messages_from_thread(self, running_thread, decode_format=None):
         - ``decode_format`` (str) - If you need to decode data to specific format
             (See https://docs.python.org/3/library/codecs.html#standard-encodings). Default: None.
         """
-        records = self._decode_data(
-            data=running_thread.get_messages(),
-            decode_format=decode_format
-        )
+        records = running_thread.get_messages()
+        if records:
+            records = self._decode_data(records, decode_format)
         return records
 
     def get_thread_group_id(self, running_thread):

src/ConfluentKafkaLibrary/version.py

@@ -1 +1 @@
-VERSION = '2.0.2-2'
+VERSION = '2.0.2-3'