openstack/deb-python-kafka
Code Issues Proposed changes

fixup kafka consumer docstring

Browse Source
This commit is contained in:
Dana Powers
2015-03-08 23:54:54 -07:00
parent 484f1a4722
commit 9be4146532
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/consumer/kafka.py
View File

@@ -89,7 +89,7 @@ class KafkaConsumer(object):
auto_offset_reset (str, optional): A policy for resetting offsets on auto_offset_reset (str, optional): A policy for resetting offsets on
OffsetOutOfRange errors. 'smallest' will move to the oldest OffsetOutOfRange errors. 'smallest' will move to the oldest
available message, 'largest' will move to the most recent. Any available message, 'largest' will move to the most recent. Any
ofther value will raise the exception. Defaults to 'smallest'. ofther value will raise the exception. Defaults to 'largest'.
deserializer_class (callable, optional): Any callable that takes a deserializer_class (callable, optional): Any callable that takes a
raw message value and returns a deserialized value. Defaults to raw message value and returns a deserialized value. Defaults to
lambda msg: msg. lambda msg: msg.