diff --git a/engine/lite/k8sDeploymentManager/src/test/scala/pl/touk/nussknacker/k8s/manager/K8sDeploymentManagerKafkaTest.scala b/engine/lite/k8sDeploymentManager/src/test/scala/pl/touk/nussknacker/k8s/manager/K8sDeploymentManagerKafkaTest.scala
index 9aeb4b74c34..66c3e81c28a 100644
--- a/engine/lite/k8sDeploymentManager/src/test/scala/pl/touk/nussknacker/k8s/manager/K8sDeploymentManagerKafkaTest.scala
+++ b/engine/lite/k8sDeploymentManager/src/test/scala/pl/touk/nussknacker/k8s/manager/K8sDeploymentManagerKafkaTest.scala
@@ -148,19 +148,19 @@ class K8sDeploymentManagerKafkaTest
 //          ).asJava
 //        )
 //      )
-//      .withValue(
-//        "resources",
-//        fromMap(
-//          Map(
-//            "requests" -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava),
-//            "limits"   -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava)
-//          ).asJava
-//        )
-//      )
+      .withValue(
+        "resources",
+        fromMap(
+          Map(
+            "requests" -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava),
+            "limits"   -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava)
+          ).asJava
+        )
+      )
       .root()
     val f = createKafkaFixture(
       deployConfig = kafkaDeployConfig
-//        .withValue("k8sDeploymentConfig.spec.replicas", fromAnyRef(3))
+        .withValue("k8sDeploymentConfig.spec.replicas", fromAnyRef(3))
         .withValue(
           "k8sDeploymentConfig.spec.template.spec.containers",
           fromIterable(List(runtimeContainerConfig).asJava)
@@ -169,7 +169,7 @@ class K8sDeploymentManagerKafkaTest
     f.withRunningScenario {
       eventually {
         val pods = k8s.listSelected[ListResource[Pod]](requirementForName(f.version.processName)).futureValue.items
-        pods.size shouldBe 1
+        pods.size shouldBe 3
         forAll(pods.head.spec.get.containers) { container =>
           container.resources shouldBe Some(
             skuber.Resource.Requirements(