diff --git a/test/basic-produce-consume.yml b/test/basic-produce-consume.yml
index 128a00a9..32ec4ec4 100644
--- a/test/basic-produce-consume.yml
+++ b/test/basic-produce-consume.yml
@@ -36,7 +36,31 @@ data:
     #pkill java
 
     exit 0
-
+---
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: basic-produce-consume
+  namespace: test-kafka
+spec:
+  template:
+    spec:
+      containers:
+      - name: topic-create
+        image: solsson/kafka:1.0.0@sha256:17fdf1637426f45c93c65826670542e36b9f3394ede1cb61885c6a4befa8f72d
+        command:
+        - ./bin/kafka-topics.sh
+        - --zookeeper
+        -   zookeeper.kafka.svc.cluster.local:2181
+        - --create
+        - --if-not-exists
+        - --topic
+        -   test-basic-produce-consume
+        - --partitions
+        -   "1"
+        - --replication-factor
+        -   "2"
+      restartPolicy: Never
 ---
 apiVersion: apps/v1beta1
 kind: Deployment
diff --git a/test/basic-with-kafkacat.yml b/test/basic-with-kafkacat.yml
index 405a7980..78e423ce 100644
--- a/test/basic-with-kafkacat.yml
+++ b/test/basic-with-kafkacat.yml
@@ -23,7 +23,6 @@ data:
     kafkacat -C -b $BOOTSTRAP -t test-basic-with-kafkacat -o -1 -e | grep $unique
 
     exit 0
-
 ---
 apiVersion: batch/v1
 kind: Job
@@ -47,7 +46,7 @@ spec:
         - --partitions
         -   "1"
         - --replication-factor
-        -   "1"
+        -   "2"
       restartPolicy: Never
 ---
 apiVersion: apps/v1beta1