diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-04-04 20:19:40 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-04-04 20:19:40 -0700 |
| commit | 87b2ca8e60832170a3c4ab3e391509ce40cb6faa (patch) | |
| tree | fc7ed1af88bcd563e6c193fde1ef58dcb635311c /kafka/protocol.py | |
| parent | e99a751081f59189ed818220100a1db2d8a13b6f (diff) | |
| download | kafka-python-87b2ca8e60832170a3c4ab3e391509ce40cb6faa.tar.gz | |
call _consume_topic_partition() before storing offset
in KafkaConsumer.set_topic_partitions((topic, partition, offset))
Diffstat (limited to 'kafka/protocol.py')
0 files changed, 0 insertions, 0 deletions