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

1 files changed, 4 insertions, 2 deletions

diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py
index 125df2c..71fd26c 100644
--- a/test/test_producer_integration.py
+++ b/test/test_producer_integration.py
@@ -9,7 +9,8 @@ from kafka import (
 )
 from kafka.codec import has_snappy
 from kafka.common import (
-    FetchRequest, ProduceRequest, UnknownTopicOrPartitionError
+    FetchRequest, ProduceRequest,
+    UnknownTopicOrPartitionError, LeaderNotAvailableError
 )
 
 from test.fixtures import ZookeeperFixture, KafkaFixture
@@ -165,7 +166,8 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase):
         producer = SimpleProducer(self.client)
 
         # At first it doesn't exist
-        with self.assertRaises(UnknownTopicOrPartitionError):
+        with self.assertRaises((UnknownTopicOrPartitionError,
+                                LeaderNotAvailableError)):
             producer.send_messages(new_topic, self.msg("one"))
 
     @kafka_versions("all")