2.10.0 (#62)

* Update to 2.10

* Add kwargs to describe_groups

* Add ConsumerGroupTypes

Author: robooo

pyproject.toml

@@ -21,7 +21,7 @@ classifiers = [
 requires-python = ">=3.8"
 dependencies = [
     "robotframework >= 3.2.1",
-    "confluent-kafka == 2.9.0",
+    "confluent-kafka == 2.10.0",
     "requests >= 2.25.1",
 ]
 

src/ConfluentKafkaLibrary/__init__.py

@@ -96,6 +96,9 @@ def _set_globals_variables_if_robot_running(self):
             BuiltIn().set_global_variable('${CONSUMER_GROUP_STATE_DEAD}', confluent_kafka.ConsumerGroupState.DEAD)
             BuiltIn().set_global_variable('${CONSUMER_GROUP_STATE_EMPTY}', confluent_kafka.ConsumerGroupState.EMPTY)
 
+            BuiltIn().set_global_variable('${CONSUMER_GROUP_TYPE_UNKNOWN}', confluent_kafka.ConsumerGroupType.UNKNOWN)
+            BuiltIn().set_global_variable('${CONSUMER_GROUP_TYPE_CONSUMER}', confluent_kafka.ConsumerGroupType.CONSUMER)
+            BuiltIn().set_global_variable('${CONSUMER_GROUP_TYPE_CLASSIC}', confluent_kafka.ConsumerGroupType.CLASSIC)
         except RobotNotRunningError as e:
             pass
 

src/ConfluentKafkaLibrary/admin_client.py

@@ -39,13 +39,13 @@ def list_groups(self, group_id, states=None, request_timeout=10):
         future = self.admin_clients[group_id].list_consumer_groups(request_timeout=request_timeout, states=set(states))
         return future.result()
 
-    def describe_groups(self, group_id, group_ids, request_timeout=10):
+    def describe_groups(self, group_id, group_ids, request_timeout=10, **kwargs):
         """Describe consumer groups.
         - ``group_ids`` (list(str)): List of group_ids which need to be described.
         - ``request_timeout`` (int): Maximum response time before timing out.
             Default: `10`.
         """
-        response = self.admin_clients[group_id].describe_consumer_groups(group_ids, request_timeout=request_timeout)
+        response = self.admin_clients[group_id].describe_consumer_groups(group_ids, request_timeout=request_timeout, **kwargs)
 
         groups_results={}
         for con_id in group_ids:

src/ConfluentKafkaLibrary/version.py

@@ -1 +1 @@
-VERSION = '2.9.0.post1'
+VERSION = '2.10.0.post1'