diff options
author | David Arthur <mumrah@gmail.com> | 2013-05-28 10:35:40 -0400 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2013-05-28 10:35:40 -0400 |
commit | f4a326f490e347a28aa57b8b9d445c87972dc220 (patch) | |
tree | 6cffe7144a4b64f116207525b2f5a5af4878921e /test | |
parent | 7ab7690422ff8d66ecea22914931328a331e30d2 (diff) | |
download | kafka-python-f4a326f490e347a28aa57b8b9d445c87972dc220.tar.gz |
Closes #22
Removed get_messages API, added test for get_pending
Diffstat (limited to 'test')
-rw-r--r-- | test/integration.py | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/test/integration.py b/test/integration.py index 609cfc6..68e0e25 100644 --- a/test/integration.py +++ b/test/integration.py @@ -456,6 +456,27 @@ class TestConsumer(unittest.TestCase): self.assertEquals(len(all_messages), 13) + def test_pending(self): + # Produce 10 messages to partition 0 and 1 + + produce1 = ProduceRequest("test_pending", 0, messages=[ + create_message("Test message 0 %d" % i) for i in range(10) + ]) + for resp in self.client.send_produce_request([produce1]): + self.assertEquals(resp.error, 0) + self.assertEquals(resp.offset, 0) + + produce2 = ProduceRequest("test_pending", 1, messages=[ + create_message("Test message 1 %d" % i) for i in range(10) + ]) + for resp in self.client.send_produce_request([produce2]): + self.assertEquals(resp.error, 0) + self.assertEquals(resp.offset, 0) + + consumer = SimpleConsumer(self.client, "group1", "test_pending") + self.assertEquals(consumer.pending(), 20) + self.assertEquals(consumer.pending(partitions=[0]), 10) + self.assertEquals(consumer.pending(partitions=[1]), 10) if __name__ == "__main__": logging.basicConfig(level=logging.DEBUG) |