diff options
| author | David Arthur <mumrah@gmail.com> | 2013-04-02 19:55:51 -0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-04-02 20:20:32 -0400 |
| commit | c275c023c5958c3b2b7d1aaf8642f2475d7780c8 (patch) | |
| tree | a935408a6651558c541ca14759f2c8bdc472f23c /kafka | |
| parent | 2690a5da966176a9259dcb992e6a927aa9193c60 (diff) | |
| download | kafka-python-c275c023c5958c3b2b7d1aaf8642f2475d7780c8.tar.gz | |
Update kafka-src to latest trunk, enable 0.8.1 features
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: |