diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-21 01:44:53 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-28 13:45:25 -0800 |
| commit | a57ab55a5c593c099453f988dc12a1ee3552ecc3 (patch) | |
| tree | cab68343441ac6ba8534f9e7d47af14e203722d2 /kafka/protocol/offset.py | |
| parent | d2af5b37ce53fcde6e9f3ee1b587c1ee1de19d2c (diff) | |
| download | kafka-python-a57ab55a5c593c099453f988dc12a1ee3552ecc3.tar.gz | |
Add OffsetResetStrategy enum class to kafka.protocol.offset
Diffstat (limited to 'kafka/protocol/offset.py')
| -rw-r--r-- | kafka/protocol/offset.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py index 776de39..606f1f1 100644 --- a/kafka/protocol/offset.py +++ b/kafka/protocol/offset.py @@ -1,6 +1,11 @@ from .struct import Struct from .types import Array, Int16, Int32, Int64, Schema, String +class OffsetResetStrategy(object): + LATEST = -1 + EARLIEST = -2 + NONE = 0 + class OffsetResponse(Struct): SCHEMA = Schema( |