Skip to content

Commit e54cabd

Browse files
authored
fix(event_sources): change partition and offset field types in KafkaEventRecord (#4515)
fix: Change partition and offset on the KafkaEventRecord to be an int type.
1 parent dedbdef commit e54cabd

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

aws_lambda_powertools/utilities/data_classes/kafka_event.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,12 @@ def topic(self) -> str:
1515
return self["topic"]
1616

1717
@property
18-
def partition(self) -> str:
18+
def partition(self) -> int:
1919
"""The Kafka record parition."""
2020
return self["partition"]
2121

2222
@property
23-
def offset(self) -> str:
23+
def offset(self) -> int:
2424
"""The Kafka record offset."""
2525
return self["offset"]
2626

0 commit comments

Comments
 (0)