diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-12 14:56:58 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-12 14:56:58 +0530 |
| commit | ab72da3db32556b04d45954da8cf6c462dc53434 (patch) | |
| tree | ee656a89aa436343536f40859af8b6b3c93bf091 /test/test_integration.py | |
| parent | 77b8301e253774e09d13ff6b7c132fd51e6d9091 (diff) | |
| download | kafka-python-ab72da3db32556b04d45954da8cf6c462dc53434.tar.gz | |
Add support to consume messages from specific partitions
Currently the kafka SimpleConsumer consumes messages from all
partitions. This commit will ensure that data is consumed only
from partitions specified during init
Diffstat (limited to 'test/test_integration.py')
0 files changed, 0 insertions, 0 deletions