From c666b4e251757b827d52d62f9d4a18ab5e728897 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Mon, 28 May 2018 15:58:26 -0700 Subject: Don't use `kafka.common` internally This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. --- kafka/producer/kafka.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'kafka/producer/kafka.py') 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__) -- cgit v1.2.1