From f722688e56d55c87f34c7410d1ff8ce6c8bc3f10 Mon Sep 17 00:00:00 2001 From: Joohwan Oh Date: Wed, 10 May 2017 01:20:07 -0700 Subject: [PATCH] Update docstring for Worker class --- kq/worker.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kq/worker.py b/kq/worker.py index 119a6e1..fac88e2 100644 --- a/kq/worker.py +++ b/kq/worker.py @@ -34,6 +34,7 @@ class Worker(object): keyfile='/my/files/keyfile', crlfile='/my/files/crlfile', proc_ttl=2000, + offset_policy='earliest' ) worker.start() @@ -96,7 +97,7 @@ class Worker(object): :type proc_ttl: int :param offset_policy: Policy for resetting offsets on the Kafka consumer. Value ``"earliest"`` moves the offset to the oldest available message - and ``"latest"`` to the most recent. Default: 'latest'. + and ``"latest"`` to the most recent. Default: ``"latest"``. :type offset_policy: str | unicode """