diff options
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 21 |
1 files changed, 10 insertions, 11 deletions
diff --git a/kafka/common.py b/kafka/common.py index 3fb5ab2..382867c 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -2,9 +2,8 @@ import inspect import sys from collections import namedtuple -############### -# Structs # -############### + +# SimpleClient Payload Structs - Deprecated # https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-MetadataAPI MetadataRequest = namedtuple("MetadataRequest", @@ -57,29 +56,29 @@ OffsetFetchResponsePayload = namedtuple("OffsetFetchResponsePayload", # Other useful structs +TopicPartition = namedtuple("TopicPartition", + ["topic", "partition"]) + BrokerMetadata = namedtuple("BrokerMetadata", ["nodeId", "host", "port"]) -TopicMetadata = namedtuple("TopicMetadata", - ["topic", "error", "partitions"]) - PartitionMetadata = namedtuple("PartitionMetadata", ["topic", "partition", "leader", "replicas", "isr", "error"]) +OffsetAndMetadata = namedtuple("OffsetAndMetadata", + ["offset", "metadata"]) + + +# Deprecated structs OffsetAndMessage = namedtuple("OffsetAndMessage", ["offset", "message"]) Message = namedtuple("Message", ["magic", "attributes", "key", "value"]) -TopicPartition = namedtuple("TopicPartition", - ["topic", "partition"]) - KafkaMessage = namedtuple("KafkaMessage", ["topic", "partition", "offset", "key", "value"]) -OffsetAndMetadata = namedtuple("OffsetAndMetadata", - ["offset", "metadata"]) # Define retry policy for async producer # Limit value: int >= 0, 0 means no retries |