Skip to content

Commit 3d9dd70

Browse files
address PR feedback
1 parent 4c8b957 commit 3d9dd70

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

aws_lambda_powertools/utilities/data_classes/kafka_event.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -97,17 +97,14 @@ def event_source(self) -> str:
9797
return self["eventSource"]
9898

9999
@property
100-
def event_source_arn(self) -> str:
100+
def event_source_arn(self) -> Optional[str]:
101101
"""The AWS service ARN from which the Kafka event record originated."""
102-
return self["eventSourceArn"]
102+
return self.get("eventSourceArn")
103103

104104
@property
105-
def bootstrap_servers(self) -> Optional[List[str]]:
105+
def bootstrap_servers(self) -> List[str]:
106106
"""The Kafka bootstrap URL."""
107-
servers = self.get("bootstrapServers")
108-
if not servers:
109-
return None
110-
return servers.split(",")
107+
return self["bootstrapServers"].split(",")
111108

112109
@property
113110
def records(self) -> Iterator[KafkaEventRecord]:

0 commit comments

Comments
 (0)