diff options
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index b9d4d9e..4ce62e2 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -108,6 +108,7 @@ class SimpleConsumer(object): partitions: list of partitions to commit, default is to commit all of them """ + raise NotImplementedError("Broker-managed offsets not supported in 0.8") # short circuit if nothing happened if self.count_since_commit == 0: |