We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a864e25 commit 041b454Copy full SHA for 041b454
aws_lambda_powertools/utilities/data_classes/kafka_event.py
@@ -102,9 +102,14 @@ def event_source_arn(self) -> Optional[str]:
102
return self.get("eventSourceArn")
103
104
@property
105
- def bootstrap_servers(self) -> List[str]:
+ def bootstrap_servers(self) -> str:
106
"""The Kafka bootstrap URL."""
107
- return self["bootstrapServers"].split(",")
+ return self["bootstrapServers"]
108
+
109
+ @property
110
+ def decoded_bootstrap_servers(self) -> List[str]:
111
+ """The decoded Kafka bootstrap URL."""
112
+ return self.bootstrap_servers.split(",")
113
114
115
def records(self) -> Iterator[KafkaEventRecord]:
0 commit comments