diff options
| -rw-r--r-- | kafka/partitioner.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/partitioner.py b/kafka/partitioner.py index 817e416..8190c34 100644 --- a/kafka/partitioner.py +++ b/kafka/partitioner.py @@ -22,7 +22,7 @@ class Partitioner(object): may look like an overhead, but it will be useful (in future) when we handle cases like rebalancing """ - raise NotImplemented('partition function has to be implemented') + raise NotImplementedError('partition function has to be implemented') class RoundRobinPartitioner(Partitioner): |