From a3f701b1d6cec7785e783edabc657ae1a4361877 Mon Sep 17 00:00:00 2001 From: Thibault Person Date: Tue, 14 Nov 2023 14:17:26 +0100 Subject: [PATCH] Allow to specify logger in Admin client --- src/confluent_kafka/admin/__init__.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/confluent_kafka/admin/__init__.py b/src/confluent_kafka/admin/__init__.py index 924361f2e..718153a03 100644 --- a/src/confluent_kafka/admin/__init__.py +++ b/src/confluent_kafka/admin/__init__.py @@ -109,7 +109,7 @@ class AdminClient (_AdminClientImpl): Requires broker version v0.11.0.0 or later. """ - def __init__(self, conf): + def __init__(self, conf, **kwargs): """ Create a new AdminClient using the provided configuration dictionary. @@ -119,7 +119,7 @@ def __init__(self, conf): At least 'bootstrap.servers' should be configured. """ - super(AdminClient, self).__init__(conf) + super(AdminClient, self).__init__(conf, **kwargs) @staticmethod def _make_topics_result(f, futmap):