diff --git a/docs/09-Configuration reference/settings.catalog.json b/docs/09-Configuration reference/settings.catalog.json
index acbaeed88..1425eff8c 100644
--- a/docs/09-Configuration reference/settings.catalog.json	
+++ b/docs/09-Configuration reference/settings.catalog.json	
@@ -42,7 +42,7 @@
       "valueType": "string",
       "default": "defaultCaddyImage",
       "sources": [
-        "internal/resources/registries/image.go:50"
+        "internal/resources/registries/image.go:44"
       ]
     },
     {
diff --git a/internal/resources/benthos/controller.go b/internal/resources/benthos/controller.go
index 77a740c71..2f014c456 100644
--- a/internal/resources/benthos/controller.go
+++ b/internal/resources/benthos/controller.go
@@ -200,7 +200,7 @@ func createDeployment(ctx Context, stack *v1beta1.Stack, b *v1beta1.Benthos) err
 	}
 
 	cmd := []string{
-		"/benthos",
+		"/redpanda-connect",
 		"-r", "/resources/*.yaml",
 		"-t", "/templates/*.yaml",
 	}
@@ -311,7 +311,7 @@ func createDeployment(ctx Context, stack *v1beta1.Stack, b *v1beta1.Benthos) err
 		return streams[i].Name < streams[j].Name
 	})
 
-	benthosImage, err := registries.GetBenthosImage(ctx, stack, "v4.23.1-es")
+	benthosImage, err := registries.GetBenthosImage(ctx, stack, "4.93.0")
 	if err != nil {
 		return err
 	}
diff --git a/internal/resources/registries/image.go b/internal/resources/registries/image.go
index 73c3d8361..63ebd7763 100644
--- a/internal/resources/registries/image.go
+++ b/internal/resources/registries/image.go
@@ -8,12 +8,6 @@ import (
 	"github.com/formancehq/operator/v3/internal/resources/settings"
 )
 
-// Format Accepted:
-// ENDPOINT/ORGANIZATION/REPOSITORY:VERSION
-// ghcr.io/<organization>/<repository>:<version>
-// public.ecr.aws/<organization>/jeffail/benthos
-// docker.io/<organization|user>/<image>:<version>
-
 func NormalizeVersion(version string) string {
 	if version == "" {
 		version = "latest"
@@ -33,7 +27,7 @@ func GetBenthosImage(ctx core.Context, stack *v1beta1.Stack, version string) (*I
 	return GetImageConfiguration(
 		ctx,
 		stack.Name,
-		fmt.Sprintf("public.ecr.aws/formance-internal/jeffail/benthos:%s", NormalizeVersion(version)),
+		fmt.Sprintf("docker.io/redpandadata/connect:%s", NormalizeVersion(version)),
 	)
 }
 
diff --git a/tests/e2e/chainsaw/23-benthos-module/chainsaw-test.yaml b/tests/e2e/chainsaw/23-benthos-module/chainsaw-test.yaml
index 8e42a17ea..e2a873f4a 100644
--- a/tests/e2e/chainsaw/23-benthos-module/chainsaw-test.yaml
+++ b/tests/e2e/chainsaw/23-benthos-module/chainsaw-test.yaml
@@ -49,7 +49,7 @@ spec:
               kubectl wait --for=jsonpath='{.status.ready}'=true benthos/chainsaw-benthos --timeout=2m
               kubectl wait --for=create deployment/benthos -n chainsaw-benthos --timeout=2m
               kubectl wait --for=create service/benthos -n chainsaw-benthos --timeout=2m
-              kubectl wait --for=jsonpath='{.spec.template.spec.containers[0].image}'=public.ecr.aws/formance-internal/jeffail/benthos:v4.23.1-es deployment/benthos -n chainsaw-benthos --timeout=2m
+              kubectl wait --for=jsonpath='{.spec.template.spec.containers[0].image}'=docker.io/redpandadata/connect:4.93.0 deployment/benthos -n chainsaw-benthos --timeout=2m
               kubectl wait --for=jsonpath='{.spec.ports[0].port}'=4195 service/benthos -n chainsaw-benthos --timeout=2m
               assert_jsonpath deployment/benthos '{.spec.template.spec.serviceAccountName}' 'chainsaw-benthos-sa'
               assert_jsonpath deployment/benthos '{.spec.template.spec.containers[0].ports[0].containerPort}' '4195'
@@ -64,7 +64,7 @@ spec:
               grep -Fx 'NATS_URL=nats.chainsaw-benthos.svc.cluster.local:4222' /tmp/chainsaw-benthos-env
               grep -Fx 'NATS_BIND=true' /tmp/chainsaw-benthos-env
               grep -Fx 'AWS_IAM_ENABLED=true' /tmp/chainsaw-benthos-env
-              assert_jsonpath deployment/benthos '{.spec.template.spec.containers[0].command[0]}' '/benthos'
+              assert_jsonpath deployment/benthos '{.spec.template.spec.containers[0].command[0]}' '/redpanda-connect'
               assert_jsonpath deployment/benthos '{.spec.template.spec.containers[0].command[2]}' '/resources/*.yaml'
               assert_jsonpath deployment/benthos '{.spec.template.spec.containers[0].command[4]}' '/templates/*.yaml'
               assert_jsonpath deployment/benthos '{.spec.template.spec.containers[0].command[8]}' '/streams/*.yaml'