diff options
| author | charsyam <charsyam@naver.com> | 2017-03-03 07:15:01 +0900 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-02 14:15:01 -0800 |
| commit | 3a630f2f886d9182bc6fe593d3659b0f3986fb4b (patch) | |
| tree | 6b2f539a1227065cc7dabd1e06acc74c10e49cf3 /kafka/structs.py | |
| parent | a22ea165649b3510d770243f6f3809d598cb4f81 (diff) | |
| download | kafka-python-3a630f2f886d9182bc6fe593d3659b0f3986fb4b.tar.gz | |
Add send_list_offset_request for searching offset by timestamp (#1001)
Diffstat (limited to 'kafka/structs.py')
| -rw-r--r-- | kafka/structs.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/kafka/structs.py b/kafka/structs.py index 7d1d96a..48321e7 100644 --- a/kafka/structs.py +++ b/kafka/structs.py @@ -37,9 +37,15 @@ FetchResponsePayload = namedtuple("FetchResponsePayload", OffsetRequestPayload = namedtuple("OffsetRequestPayload", ["topic", "partition", "time", "max_offsets"]) +ListOffsetRequestPayload = namedtuple("ListOffsetRequestPayload", + ["topic", "partition", "time"]) + OffsetResponsePayload = namedtuple("OffsetResponsePayload", ["topic", "partition", "error", "offsets"]) +ListOffsetResponsePayload = namedtuple("ListOffsetResponsePayload", + ["topic", "partition", "error", "timestamp", "offset"]) + # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI OffsetCommitRequestPayload = namedtuple("OffsetCommitRequestPayload", ["topic", "partition", "offset", "metadata"]) |