From cf74437fa8fc200c16a2b4d69f5d12331075ff9c Mon Sep 17 00:00:00 2001 From: Sean Campbell Date: Thu, 13 Jun 2024 18:45:29 -0400 Subject: [PATCH] fix: Change partition and offset on the KafkaEventRecord to be an int type. --- aws_lambda_powertools/utilities/data_classes/kafka_event.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/aws_lambda_powertools/utilities/data_classes/kafka_event.py b/aws_lambda_powertools/utilities/data_classes/kafka_event.py index f20c5254730..3b5a60c583c 100644 --- a/aws_lambda_powertools/utilities/data_classes/kafka_event.py +++ b/aws_lambda_powertools/utilities/data_classes/kafka_event.py @@ -15,12 +15,12 @@ def topic(self) -> str: return self["topic"] @property - def partition(self) -> str: + def partition(self) -> int: """The Kafka record parition.""" return self["partition"] @property - def offset(self) -> str: + def offset(self) -> int: """The Kafka record offset.""" return self["offset"]