diff --git a/pyproject.toml b/pyproject.toml index 6795b80..f0fa7fc 100644 --- a/pyproject.toml +++ b/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", ] diff --git a/src/ConfluentKafkaLibrary/__init__.py b/src/ConfluentKafkaLibrary/__init__.py index e2628d9..58b44cd 100644 --- a/src/ConfluentKafkaLibrary/__init__.py +++ b/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 diff --git a/src/ConfluentKafkaLibrary/admin_client.py b/src/ConfluentKafkaLibrary/admin_client.py index 9f6d735..290c301 100644 --- a/src/ConfluentKafkaLibrary/admin_client.py +++ b/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: diff --git a/src/ConfluentKafkaLibrary/version.py b/src/ConfluentKafkaLibrary/version.py index e813113..9792a61 100644 --- a/src/ConfluentKafkaLibrary/version.py +++ b/src/ConfluentKafkaLibrary/version.py @@ -1 +1 @@ -VERSION = '2.9.0.post1' +VERSION = '2.10.0.post1'