diff options
| author | Dana Powers <dana.powers@rd.io> | 2014-09-08 13:15:56 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2014-09-08 13:17:43 -0700 |
| commit | fff812ddc80243208233f785b3f005904cf33482 (patch) | |
| tree | 30f1eb703dcd8ce1063c413fd70ac11f3fff5072 /kafka/queue.py | |
| parent | 42a7ab18bb84fea60deed5f7e3a6cfdfaaaeecd6 (diff) | |
| parent | 0dabb1fbe8a9f538527a03c2903475ed77a12c10 (diff) | |
| download | kafka-python-fff812ddc80243208233f785b3f005904cf33482.tar.gz | |
Merge pull request #223 from dpkp/metadata_refactor
Metadata Refactor
* add MetadataRequest and MetadataResponse namedtuples
* add TopicMetadata namedtuple
* add error codes to Topic and Partition Metadata
* add KafkaClient.send_metadata_request() method
* KafkaProtocol.decode_metadata_response changed to return a
MetadataResponse object so that it is consistent with server api:
[broker_list, topic_list]
* raise server exceptions in load_metadata_for_topics(*topics)
unless topics is null (full refresh)
* Replace non-standard exceptions (LeaderUnavailable,
PartitionUnavailable) with server standard exceptions
(LeaderNotAvailableError, UnknownTopicOrPartitionError)
Conflicts:
kafka/client.py
test/test_client.py
test/test_producer_integration.py
test/test_protocol.py
Diffstat (limited to 'kafka/queue.py')
0 files changed, 0 insertions, 0 deletions