diff --git a/localstack/services/lambda_/provider.py b/localstack/services/lambda_/provider.py
index 02f7e10f5b003..04081edf34d28 100644
--- 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.",