Don't use `kafka.common` internally1.3.5

This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.

1 files changed, 4 insertions, 4 deletions

diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index f285ab4..7d52bdf 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -10,18 +10,18 @@ import weakref
 
 from kafka.vendor import six
 
-from kafka import errors as Errors
+import kafka.errors as Errors
 from kafka.client_async import KafkaClient, selectors
 from kafka.codec import has_gzip, has_snappy, has_lz4
 from kafka.metrics import MetricConfig, Metrics
 from kafka.partitioner.default import DefaultPartitioner
+from kafka.producer.future import FutureRecordMetadata, FutureProduceResult
+from kafka.producer.record_accumulator import AtomicInteger, RecordAccumulator
+from kafka.producer.sender import Sender
 from kafka.record.default_records import DefaultRecordBatchBuilder
 from kafka.record.legacy_records import LegacyRecordBatchBuilder
 from kafka.serializer import Serializer
 from kafka.structs import TopicPartition
-from kafka.producer.future import FutureRecordMetadata, FutureProduceResult
-from kafka.producer.record_accumulator import AtomicInteger, RecordAccumulator
-from kafka.producer.sender import Sender
 
 
 log = logging.getLogger(__name__)