diff options
Diffstat (limited to 'kafka/structs.py')
| -rw-r--r-- | kafka/structs.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/structs.py b/kafka/structs.py index e15e92e..baacbcd 100644 --- a/kafka/structs.py +++ b/kafka/structs.py @@ -72,6 +72,7 @@ PartitionMetadata = namedtuple("PartitionMetadata", ["topic", "partition", "leader", "replicas", "isr", "error"]) OffsetAndMetadata = namedtuple("OffsetAndMetadata", + # TODO add leaderEpoch: OffsetAndMetadata(offset, leaderEpoch, metadata) ["offset", "metadata"]) OffsetAndTimestamp = namedtuple("OffsetAndTimestamp", |