From 3a630f2f886d9182bc6fe593d3659b0f3986fb4b Mon Sep 17 00:00:00 2001 From: charsyam Date: Fri, 3 Mar 2017 07:15:01 +0900 Subject: Add send_list_offset_request for searching offset by timestamp (#1001) --- kafka/structs.py | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'kafka/structs.py') 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"]) -- cgit v1.2.1