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..ec47a3e40 100644
--- a/internal/resources/registries/image.go
+++ b/internal/resources/registries/image.go
@@ -11,7 +11,6 @@ import (
 // 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 {
@@ -33,7 +32,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("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..8a8feaedf 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}'=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'