diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 23:09:15 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 23:09:15 +0300 |
| commit | 7d6f3f541e0c380c0600eb607d927ec8f8cc966f (patch) | |
| tree | 9d858a24df0231433204e44738e2f5a9f1be8a66 /test/test_producer.py | |
| parent | 4474a50162f73aaabe770ee6dce9bd9b2110b2d5 (diff) | |
| download | kafka-python-7d6f3f541e0c380c0600eb607d927ec8f8cc966f.tar.gz | |
Check response.error for async producer
Diffstat (limited to 'test/test_producer.py')
| -rw-r--r-- | test/test_producer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_producer.py b/test/test_producer.py index a2ba877..258b9c3 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -143,7 +143,7 @@ class TestKafkaProducerSendUpstream(unittest.TestCase): def send_side_effect(reqs, *args, **kwargs): if self.client.is_first_time: self.client.is_first_time = False - return [[FailedPayloadsError(reqs)]] + return [FailedPayloadsError(reqs)] return [] self.client.send_produce_request.side_effect = send_side_effect @@ -165,7 +165,7 @@ class TestKafkaProducerSendUpstream(unittest.TestCase): self.queue.put((TopicAndPartition("test", i), "msg %i" % i, "key %i" % i)) def send_side_effect(reqs, *args, **kwargs): - return [[FailedPayloadsError(reqs)]] + return [FailedPayloadsError(reqs)] self.client.send_produce_request.side_effect = send_side_effect |