diff --git a/examples/kafka/default.yaml b/examples/kafka/default.yaml
index 5da88b7..51397a9 100644
--- a/examples/kafka/default.yaml
+++ b/examples/kafka/default.yaml
@@ -26,8 +26,11 @@ spec:
       default.replication.factor: 1
       min.insync.replicas: 1
       inter.broker.protocol.version: "3.1"
+      auto.create.topics.enable: false
     storage:
-      type: ephemeral
+      type: persistent-claim 
+      size: 200Gi 
+      class: ${DEFAULT_SC}
     metricsConfig:
       type: jmxPrometheusExporter
       valueFrom:
@@ -35,9 +38,11 @@ spec:
           name: kafka-metrics
           key: kafka-metrics-config.yml
   zookeeper:
-    replicas: 1
+    replicas: 3
     storage:
-      type: ephemeral
+      type: persistent-claim 
+      size: 20Gi 
+      class: ${DEFAULT_SC}
     metricsConfig:
       type: jmxPrometheusExporter
       valueFrom:
diff --git a/examples/kafka/tls.yaml b/examples/kafka/tls.yaml
index 1f15070..b024f46 100644
--- a/examples/kafka/tls.yaml
+++ b/examples/kafka/tls.yaml
@@ -27,7 +27,9 @@ spec:
       min.insync.replicas: 1
       inter.broker.protocol.version: "3.1"
     storage:
-      type: ephemeral
+      type: persistent-claim 
+      size: 200Gi 
+      class: ${DEFAULT_SC}
     metricsConfig:
       type: jmxPrometheusExporter
       valueFrom:
@@ -35,9 +37,11 @@ spec:
           name: kafka-metrics
           key: kafka-metrics-config.yml
   zookeeper:
-    replicas: 1
+    replicas: 3
     storage:
-      type: ephemeral
+      type: persistent-claim 
+      size: 20Gi 
+      class: ${DEFAULT_SC}
     metricsConfig:
       type: jmxPrometheusExporter
       valueFrom:
diff --git a/kafka.md b/kafka.md
index 94e2b86..53266e6 100644
--- a/kafka.md
+++ b/kafka.md
@@ -12,6 +12,12 @@ You can use the following command to deploy the strimzi operator :
 export NAMESPACE=netobserv
 kubectl create -f "https://strimzi.io/install/latest?namespace=$NAMESPACE" -n $NAMESPACE
 ```
+## Update storage class of kafka cluster
+```
+export DEFAULT_SC=$(kubectl get storageclass -o=jsonpath='{.items[?(@.metadata.annotations.storageclass\.kubernetes\.io/is-default-class=="true")].metadata.name}')
+tmpfile=$(mktemp)
+envsubst < ./examples/kafka/default.yaml > $tmpfile && mv $tmpfile ./examples/kafka/default.yaml
+```
 
 ## Creating the default cluster