diff options
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/client.py | 2 | ||||
| -rw-r--r-- | kafka/consumer.py | 1 |
2 files changed, 0 insertions, 3 deletions
diff --git a/kafka/client.py b/kafka/client.py index 1c7fc93..8498a08 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -216,7 +216,6 @@ class KafkaClient(object): return out def send_offset_commit_request(self, group, payloads=[], fail_on_error=True, callback=None): - raise NotImplementedError("Broker-managed offsets not supported in 0.8") resps = self._send_broker_aware_request(payloads, partial(KafkaProtocol.encode_offset_commit_request, group=group), KafkaProtocol.decode_offset_commit_response) @@ -231,7 +230,6 @@ class KafkaClient(object): return out def send_offset_fetch_request(self, group, payloads=[], fail_on_error=True, callback=None): - raise NotImplementedError("Broker-managed offsets not supported in 0.8") resps = self._send_broker_aware_request(payloads, partial(KafkaProtocol.encode_offset_commit_fetch, group=group), KafkaProtocol.decode_offset_fetch_response) 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: |