Remove oauth_cb workaround for KIP-768 support

nasa-gcn · Dec 4, 2024 · 72aca78 · 72aca78
1 parent 110db61
commit 72aca78
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 77 deletions.
diff --git a/gcn_kafka/core.py b/gcn_kafka/core.py
@@ -7,8 +7,6 @@
 import confluent_kafka
 import confluent_kafka.admin
 
-from .oidc import set_oauth_cb
-
 
 def get_config(mode, config, **kwargs):
     # Merge configuration from user.
@@ -46,7 +44,6 @@ def get_config(mode, config, **kwargs):
     if mode == "producer":
         config.setdefault("compression.type", "zstd")
 
-    set_oauth_cb(config)
     return config
 
 
@@ -81,9 +78,6 @@ def __init__(
                 **kwargs,
             )
         )
-        # Workaround for https://github.com/confluentinc/librdkafka/issues/3753#issuecomment-1058272987.
-        # FIXME: Remove once fixed upstream, or on removal of oauth_cb.
-        self.poll(0)
 
 
 class Consumer(confluent_kafka.Consumer):
@@ -111,9 +105,6 @@ def __init__(
                 **kwargs,
             )
         )
-        # Workaround for https://github.com/confluentinc/librdkafka/issues/3753#issuecomment-1058272987.
-        # FIXME: Remove once fixed upstream, or on removal of oauth_cb.
-        self.poll(0)
 
 
 class AdminClient(confluent_kafka.admin.AdminClient):
@@ -141,6 +132,3 @@ def __init__(
                 **kwargs,
             )
         )
-        # Workaround for https://github.com/confluentinc/librdkafka/issues/3753#issuecomment-1058272987.
-        # FIXME: Remove once fixed upstream, or on removal of oauth_cb.
-        self.poll(0)
diff --git a/gcn_kafka/oidc.py b/gcn_kafka/oidc.py
diff --git a/gcn_kafka/test/test_oidc.py b/gcn_kafka/test/test_oidc.py
diff --git a/pyproject.toml b/pyproject.toml
@@ -20,10 +20,8 @@ classifiers = [
     "Topic :: System :: Networking"
 ]
 dependencies = [
-    "authlib",
     "certifi",
     "confluent-kafka >= 2.2.0",
-    "requests",
 ]
 requires-python = ">=3.9"
 dynamic = [ "version" ]