diff options
| author | Dana Powers <dana.powers@rd.io> | 2014-08-27 13:16:09 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2014-08-27 13:26:23 -0700 |
| commit | 9cac8eacb2c3776d048500c4bfbcd2ee33ff9c02 (patch) | |
| tree | c2086622d834c08ccf76e4188de7433f78e7e5ee /kafka/context.py | |
| parent | 7c830590bf891913d309c45be53db08e7220b4a0 (diff) | |
| download | kafka-python-9cac8eacb2c3776d048500c4bfbcd2ee33ff9c02.tar.gz | |
Fixup producer failover tests to avoid consumer message count flap
check message counts via consumer.pending() (OffsetRequest)
rather than relying on consumer message iterator (FetchRequest)
Diffstat (limited to 'kafka/context.py')
0 files changed, 0 insertions, 0 deletions