Skip to content

Commit 4f2007e

Browse files
lpsingercnweaver
authored andcommitted
Remove oauth_cb workaround for KIP-768 support
Fixes #71. See nasa-gcn/gcn-kafka-python#22.
1 parent 2f3fcca commit 4f2007e

File tree

4 files changed

+2
-32
lines changed

4 files changed

+2
-32
lines changed

adc/auth.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ def __init__(self, user, password, ssl=True, method=None, token_endpoint=None, *
6464
self._config = {
6565
"security.protocol": "SASL_SSL",
6666
"ssl.ca.location": ssl_cert,
67+
"https.ca.location": ssl_cert,
6768
}
6869
if "ssl_endpoint_identification_algorithm" in kwargs:
6970
self._config["ssl.endpoint.identification.algorithm"] = \

adc/consumer.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414

1515
from .auth import SASLAuth
1616
from .errors import ErrorCallback, log_client_errors
17-
from .oidc import set_oauth_cb
1817

1918

2019
class LogicalOffset(enum.IntEnum):
@@ -360,5 +359,4 @@ def as_ms(td: timedelta):
360359

361360
if self.auth is not None:
362361
config.update(self.auth())
363-
set_oauth_cb(config)
364362
return config

adc/oidc.py

Lines changed: 0 additions & 27 deletions
This file was deleted.

setup.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,9 @@
33

44
# requirements
55
install_requires = [
6-
"authlib", # FIXME: drop after next release of confluent-kafka with OIDC support
7-
"confluent-kafka >= 1.6.1, != 2.1.0, != 2.1.1",
6+
"confluent-kafka >= 2.11.0",
87
"dataclasses ; python_version < '3.7'",
98
"importlib-metadata ; python_version < '3.8'",
10-
"requests", # FIXME: drop after next release of confluent-kafka with OIDC support
119
"tqdm",
1210
"certifi>=2020.04.05.1",
1311
"typing-extensions ; python_version < '3.8'",

0 commit comments

Comments
 (0)