Remove oauth_cb workaround for KIP-768 support

Fixes #49.

Author: lpsinger

pyproject.toml

@@ -21,10 +21,8 @@ classifiers = [
     "Typing :: Typed",
 ]
 dependencies = [
-    "authlib",
     "certifi",
-    "confluent-kafka >= 2.2.0",
-    "requests",
+    "confluent-kafka >= 2.11.0",
 ]
 requires-python = ">=3.9"
 dynamic = [ "version" ]

src/gcn_kafka/core.py

@@ -7,21 +7,20 @@
 import confluent_kafka
 import confluent_kafka.admin
 
-from .oidc import set_oauth_cb
-
 
 def get_config(mode, config, **kwargs):
     # Merge configuration from user.
     config = update_config(config, **kwargs)
 
     # SSL configuration.
     if config.setdefault("security.protocol", "sasl_ssl") == "sasl_ssl":
-        if not config.get("ssl.ca.location"):
-            # confluent-kafka wheels are statically linked against openssl,
-            # but _that_ version of openssl may expect to find the CA cert
-            # bundle at a different location than the users's system. Provide
-            # certificate bundle from Certifi.
-            config["ssl.ca.location"] = certifi.where()
+        # confluent-kafka wheels are statically linked against openssl,
+        # but _that_ version of openssl may expect to find the CA cert
+        # bundle at a different location than the users's system. Provide
+        # certificate bundle from Certifi.
+        default_cert_location = certifi.where()
+        config.setdefault("ssl.ca.location", default_cert_location)
+        config.setdefault("https.ca.location", default_cert_location)
 
     domain = config.pop("domain", "gcn.nasa.gov")
     client_id = config.pop("client_id", None)
@@ -46,7 +45,6 @@ def get_config(mode, config, **kwargs):
     if mode == "producer":
         config.setdefault("compression.type", "zstd")
 
-    set_oauth_cb(config)
     return config
 
 
@@ -81,9 +79,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 +106,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 +133,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)