diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-10 10:57:27 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-10 11:25:15 -0800 |
| commit | 7470cade6bb8629d17541e136527369f9d2ec387 (patch) | |
| tree | ba424c4d0cc27ffb5ec77196a0e121f3075bc992 /kafka/common.py | |
| parent | c3d2fda3c368771cb93a09bb2f1edaa7a3cf9c2b (diff) | |
| download | kafka-python-7470cade6bb8629d17541e136527369f9d2ec387.tar.gz | |
Convert OffsetCommit and OffsetFetch protocol encode/decode
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/kafka/common.py b/kafka/common.py index 7ae3294..4fc1e19 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -28,30 +28,30 @@ ProduceResponsePayload = namedtuple("ProduceResponsePayload", ["topic", "partition", "error", "offset"]) # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchAPI -FetchRequestPayload = namedtuple("FetchRequest", +FetchRequestPayload = namedtuple("FetchRequestPayload", ["topic", "partition", "offset", "max_bytes"]) -FetchResponsePayload = namedtuple("FetchResponse", +FetchResponsePayload = namedtuple("FetchResponsePayload", ["topic", "partition", "error", "highwaterMark", "messages"]) # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetAPI -OffsetRequestPayload = namedtuple("OffsetRequest", +OffsetRequestPayload = namedtuple("OffsetRequestPayload", ["topic", "partition", "time", "max_offsets"]) -OffsetResponsePayload = namedtuple("OffsetResponse", +OffsetResponsePayload = namedtuple("OffsetResponsePayload", ["topic", "partition", "error", "offsets"]) # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI -OffsetCommitRequest = namedtuple("OffsetCommitRequest", +OffsetCommitRequestPayload = namedtuple("OffsetCommitRequestPayload", ["topic", "partition", "offset", "metadata"]) -OffsetCommitResponse = namedtuple("OffsetCommitResponse", +OffsetCommitResponsePayload = namedtuple("OffsetCommitResponsePayload", ["topic", "partition", "error"]) -OffsetFetchRequest = namedtuple("OffsetFetchRequest", +OffsetFetchRequestPayload = namedtuple("OffsetFetchRequestPayload", ["topic", "partition"]) -OffsetFetchResponse = namedtuple("OffsetFetchResponse", +OffsetFetchResponsePayload = namedtuple("OffsetFetchResponsePayload", ["topic", "partition", "offset", "metadata", "error"]) |