diff --git a/e2e/cluster/base/03-flp.yml b/e2e/cluster/base/03-flp.yml
index bf5476dbde438e18e5a2f1b1fb5a2777e8e47510..24acccc7d2a2b04163b331ff83e2c41eb880e740 100644
--- a/e2e/cluster/base/03-flp.yml
+++ b/e2e/cluster/base/03-flp.yml
@@ -39,10 +39,8 @@ data:
     log-level: debug
     pipeline:
       - name: ingest
-      - name: decode
-        follows: ingest
       - name: enrich
-        follows: decode
+        follows: ingest
       - name: loki
         follows: enrich
     parameters:
@@ -51,9 +49,6 @@ data:
           type: grpc
           grpc:
             port: 9999
-      - name: decode
-        decode:
-          type: protobuf
       - name: enrich
         transform:
           type: network
diff --git a/e2e/kafka/kafka_test.go b/e2e/kafka/kafka_test.go
index a53949f1d413a737a8b18ede96c4939f2a70e9f4..ae91947287a11ab28bbd0145d173b019b2ece097 100644
--- a/e2e/kafka/kafka_test.go
+++ b/e2e/kafka/kafka_test.go
@@ -23,7 +23,7 @@ import (
 
 const (
 	clusterNamePrefix = "kafka-test-cluster"
-	testTimeout       = 10 * time.Minute
+	testTimeout       = 20 * time.Minute
 	namespace         = "default"
 )
 
diff --git a/e2e/kafka/manifests/11-kafka-cluster.yml b/e2e/kafka/manifests/11-kafka-cluster.yml
index 2dcc2678ae68f470bb8dafdec8e29f924f5c8b51..2654748e259dcacd7211289523f7706d903a1f6a 100644
--- a/e2e/kafka/manifests/11-kafka-cluster.yml
+++ b/e2e/kafka/manifests/11-kafka-cluster.yml
@@ -28,6 +28,13 @@ spec:
       inter.broker.protocol.version: "3.1"
     storage:
       type: ephemeral
+    resources:
+      limits:
+        cpu: 1000m
+        memory: 1024Mi
+      requests:
+        cpu: 250m
+        memory: 256Mi
   zookeeper:
     replicas: 1
     storage:
diff --git a/e2e/kafka/manifests/20-flp-transformer.yml b/e2e/kafka/manifests/20-flp-transformer.yml
index 090858d3683d48efff811657b40f6af3cdb3462a..af76dba289b09b2dea7f756aaf9875049b9c2bff 100644
--- a/e2e/kafka/manifests/20-flp-transformer.yml
+++ b/e2e/kafka/manifests/20-flp-transformer.yml
@@ -36,10 +36,8 @@ data:
     log-level: debug
     pipeline:
       - name: ingest
-      - name: decode
-        follows: ingest
       - name: enrich
-        follows: decode
+        follows: ingest
       - name: loki
         follows: enrich
     parameters:
@@ -50,9 +48,8 @@ data:
             brokers: ["kafka-cluster-kafka-bootstrap"]
             topic: network-flows
             groupId: kafka-transformer
-      - name: decode
-        decode:
-          type: json
+            decoder:
+              type: json
       - name: enrich
         transform:
           type: network