summaryrefslogtreecommitdiff
path: root/kafka/producer/sender.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/producer/sender.py')
-rw-r--r--kafka/producer/sender.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py
index 48ad06e..895045d 100644
--- a/kafka/producer/sender.py
+++ b/kafka/producer/sender.py
@@ -8,12 +8,12 @@ import time
from kafka.vendor import six
-from .. import errors as Errors
-from ..metrics.measurable import AnonMeasurable
-from ..metrics.stats import Avg, Max, Rate
-from ..protocol.produce import ProduceRequest
-from ..structs import TopicPartition
-from ..version import __version__
+from kafka import errors as Errors
+from kafka.metrics.measurable import AnonMeasurable
+from kafka.metrics.stats import Avg, Max, Rate
+from kafka.protocol.produce import ProduceRequest
+from kafka.structs import TopicPartition
+from kafka.version import __version__
log = logging.getLogger(__name__)