diff options
Diffstat (limited to 'kafka/producer/keyed.py')
| -rw-r--r-- | kafka/producer/keyed.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer/keyed.py b/kafka/producer/keyed.py index 9fba33b..8de3ad8 100644 --- a/kafka/producer/keyed.py +++ b/kafka/producer/keyed.py @@ -3,8 +3,8 @@ from __future__ import absolute_import import logging import warnings -from .base import Producer -from ..partitioner import HashedPartitioner +from kafka.producer.base import Producer +from kafka.partitioner import HashedPartitioner log = logging.getLogger(__name__) |