Fix parameter validation for self-managed Kafka event source mapping (l…

…ocalstack#9007)
ecampuslearning · Mar 25, 2024 · 241f5a1 · 241f5a1
1 parent 89b20aa
commit 241f5a1
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/localstack/services/lambda_/provider.py b/localstack/services/lambda_/provider.py
@@ -1689,10 +1689,15 @@ def create_event_source_mapping(
         context: RequestContext,
         request: CreateEventSourceMappingRequest,
     ) -> EventSourceMappingConfiguration:
-        if "EventSourceArn" not in request:
-            raise InvalidParameterValueException("Unrecognized event source.", Type="User")
+        service = None
+
+        if "SelfManagedEventSource" in request:
+            service = "kafka"
 
-        service = extract_service_from_arn(request["EventSourceArn"])
+        if service is None and "EventSourceArn" not in request:
+            raise InvalidParameterValueException("Unrecognized event source.", Type="User")
+        if service is None:
+            service = extract_service_from_arn(request["EventSourceArn"])
         if service in ["dynamodb", "kinesis", "kafka"] and "StartingPosition" not in request:
             raise InvalidParameterValueException(
                 "1 validation error detected: Value null at 'startingPosition' failed to satisfy constraint: Member must not be null.",