diff options
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 45 |
1 files changed, 34 insertions, 11 deletions
diff --git a/kafka/common.py b/kafka/common.py index 447684f..9aab8fc 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -5,26 +5,49 @@ from collections import namedtuple ############### # Request payloads -ProduceRequest = namedtuple("ProduceRequest", ["topic", "partition", "messages"]) -FetchRequest = namedtuple("FetchRequest", ["topic", "partition", "offset", "max_bytes"]) -OffsetRequest = namedtuple("OffsetRequest", ["topic", "partition", "time", "max_offsets"]) -OffsetCommitRequest = namedtuple("OffsetCommitRequest", ["topic", "partition", "offset", "metadata"]) +ProduceRequest = namedtuple("ProduceRequest", + ["topic", "partition", "messages"]) + +FetchRequest = namedtuple("FetchRequest", + ["topic", "partition", "offset", "max_bytes"]) + +OffsetRequest = namedtuple("OffsetRequest", + ["topic", "partition", "time", "max_offsets"]) + +OffsetCommitRequest = namedtuple("OffsetCommitRequest", + ["topic", "partition", "offset", "metadata"]) + OffsetFetchRequest = namedtuple("OffsetFetchRequest", ["topic", "partition"]) # Response payloads -ProduceResponse = namedtuple("ProduceResponse", ["topic", "partition", "error", "offset"]) -FetchResponse = namedtuple("FetchResponse", ["topic", "partition", "error", "highwaterMark", "messages"]) -OffsetResponse = namedtuple("OffsetResponse", ["topic", "partition", "error", "offsets"]) -OffsetCommitResponse = namedtuple("OffsetCommitResponse", ["topic", "partition", "error"]) -OffsetFetchResponse = namedtuple("OffsetFetchResponse", ["topic", "partition", "offset", "metadata", "error"]) +ProduceResponse = namedtuple("ProduceResponse", + ["topic", "partition", "error", "offset"]) + +FetchResponse = namedtuple("FetchResponse", ["topic", "partition", "error", + "highwaterMark", "messages"]) + +OffsetResponse = namedtuple("OffsetResponse", + ["topic", "partition", "error", "offsets"]) + +OffsetCommitResponse = namedtuple("OffsetCommitResponse", + ["topic", "partition", "error"]) + +OffsetFetchResponse = namedtuple("OffsetFetchResponse", + ["topic", "partition", "offset", + "metadata", "error"]) + BrokerMetadata = namedtuple("BrokerMetadata", ["nodeId", "host", "port"]) -PartitionMetadata = namedtuple("PartitionMetadata", ["topic", "partition", "leader", "replicas", "isr"]) -# Other useful structs +PartitionMetadata = namedtuple("PartitionMetadata", + ["topic", "partition", "leader", + "replicas", "isr"]) + +# Other useful structs OffsetAndMessage = namedtuple("OffsetAndMessage", ["offset", "message"]) Message = namedtuple("Message", ["magic", "attributes", "key", "value"]) TopicAndPartition = namedtuple("TopicAndPartition", ["topic", "partition"]) + class ErrorMapping(object): # Many of these are not actually used by the client UNKNOWN = -1 |