Move oauth

ods · Oct 22, 2023 · 417e733 · 417e733
1 parent 62a789d
commit 417e733
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 10 deletions.
diff --git a/aiokafka/consumer/consumer.py b/aiokafka/consumer/consumer.py
@@ -213,7 +213,7 @@ class AIOKafkaConsumer:
         sasl_plain_password (str): password for SASL ``PLAIN`` authentication.
             Default: None
         sasl_oauth_token_provider (~aiokafka.abc.AbstractTokenProvider):
-            OAuthBearer token provider instance. (See :mod:`kafka.oauth.abstract`).
+            OAuthBearer token provider instance. (See :mod:`aiokafka.oauth`).
             Default: None
 
     Note:

diff --git a/kafka/oauth/abstract.py → aiokafka/oauth.py b/kafka/oauth/abstract.py → aiokafka/oauth.py
@@ -1,11 +1,7 @@
-from __future__ import absolute_import
-
 import abc
 
-# This statement is compatible with both Python 2.7 & 3+
-ABC = abc.ABCMeta('ABC', (object,), {'__slots__': ()})
 
-class AbstractTokenProvider(ABC):
+class AbstractTokenProvider(abc.ABC):
     """
     A Token Provider must be used for the SASL OAuthBearer protocol.
 

diff --git a/aiokafka/producer/producer.py b/aiokafka/producer/producer.py
@@ -167,7 +167,7 @@ class AIOKafkaProducer:
             Default: :data:`None`
         sasl_oauth_token_provider (:class:`~aiokafka.abc.AbstractTokenProvider`):
             OAuthBearer token provider instance. (See
-            :mod:`kafka.oauth.abstract`).
+            :mod:`aiokafka.oauth`).
             Default: :data:`None`
 
     Note:

diff --git a/kafka/oauth/__init__.py b/kafka/oauth/__init__.py