diff options
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 4ce62e2..b9d4d9e 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -108,7 +108,6 @@ 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: |