Cleanup after kafka-python merge

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:`aiokafka.oauth`).
+            OAuthBearer token provider instance.
             Default: None
 
     Note:

aiokafka/producer/producer.py

@@ -165,8 +165,7 @@ class AIOKafkaProducer:
         sasl_plain_password (str): password for SASL ``PLAIN`` authentication.
             Default: :data:`None`
         sasl_oauth_token_provider (:class:`~aiokafka.abc.AbstractTokenProvider`):
-            OAuthBearer token provider instance. (See
-            :mod:`aiokafka.oauth`).
+            OAuthBearer token provider instance.
             Default: :data:`None`
 
     Note:

aiokafka/protocol/message.py

@@ -15,7 +15,6 @@
 from aiokafka.errors import UnsupportedCodecError
 from aiokafka.util import WeakMethod
 
-from .frame import KafkaBytes
 from .struct import Struct
 from .types import Int8, Int32, UInt32, Int64, Bytes, Schema, AbstractType
 
@@ -186,7 +185,7 @@ class MessageSet(AbstractType):
     @classmethod
     def encode(cls, items, prepend_size=True):
         # RecordAccumulator encodes messagesets internally
-        if isinstance(items, (io.BytesIO, KafkaBytes)):
+        if isinstance(items, io.BytesIO):
             size = Int32.decode(items)
             if prepend_size:
                 # rewind and return all the bytes
@@ -234,7 +233,7 @@ def decode(cls, data, bytes_to_read=None):
 
     @classmethod
     def repr(cls, messages):
-        if isinstance(messages, (KafkaBytes, io.BytesIO)):
+        if isinstance(messages, io.BytesIO):
             offset = messages.tell()
             decoded = cls.decode(messages)
             messages.seek(offset)