De-dup: record packages

ods · Oct 22, 2023 · c2041d9 · c2041d9
1 parent 57d5471
commit c2041d9
Show file tree

Hide file tree

Showing 31 changed files with 2 additions and 7,802 deletions.
diff --git a/aiokafka/consumer/fetcher.py b/aiokafka/consumer/fetcher.py
@@ -309,7 +309,7 @@ class Fetcher:
     Parameters:
         client (AIOKafkaClient): kafka client
         subscription (SubscriptionState): instance of SubscriptionState
-            located in kafka.consumer.subscription_state
+            located in aiokafka.consumer.subscription_state
         key_deserializer (callable): Any callable that takes a
             raw message key and returns a deserialized key.
         value_deserializer (callable, optional): Any callable that takes a

diff --git a/kafka/__init__.py b/kafka/__init__.py
@@ -20,9 +20,7 @@ def emit(self, record):
 
 from kafka.admin import KafkaAdminClient
 from kafka.client_async import KafkaClient
-from kafka.consumer import KafkaConsumer
 from kafka.consumer.subscription_state import ConsumerRebalanceListener
-from kafka.producer import KafkaProducer
 from kafka.conn import BrokerConnection
 from kafka.serializer import Serializer, Deserializer
 from kafka.structs import TopicPartition, OffsetAndMetadata

diff --git a/kafka/consumer/__init__.py b/kafka/consumer/__init__.py
@@ -1,7 +0,0 @@
-from __future__ import absolute_import
-
-from kafka.consumer.group import KafkaConsumer
-
-__all__ = [
-    'KafkaConsumer'
-]

diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
diff --git a/kafka/producer/__init__.py b/kafka/producer/__init__.py
diff --git a/kafka/producer/buffer.py b/kafka/producer/buffer.py
diff --git a/kafka/producer/future.py b/kafka/producer/future.py