diff --git a/kafka_docker_composer.py b/kafka_docker_composer.py
index 443f402..3d4bcd4 100644
--- a/kafka_docker_composer.py
+++ b/kafka_docker_composer.py
@@ -198,6 +198,8 @@ def generate_controller_services(self):
                 "KAFKA_BROKER_RACK": f"rack-{rack}",
                 "KAFKA_DEFAULT_REPLICATION_FACTOR": self.replication_factor(),
                 "KAFKA_OFFSET_REPLICATION_FACTOR": self.replication_factor(),
+                "KAFKA_REPLICATION_FACTOR": self.replication_factor(),
+                "KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR": self.replication_factor(),
                 "KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR": self.replication_factor(),
                 "KAFKA_CONFLUENT_LICENSE_TOPIC_REPLICATION_FACTOR": self.replication_factor(),
                 "KAFKA_CONFLUENT_METADATA_TOPIC_REPLICATION_FACTOR": self.replication_factor(),
@@ -404,6 +406,8 @@ def generate_broker_services(self):
                 "KAFKA_CONFLUENT_LICENSE_TOPIC_REPLICATION_FACTOR": self.replication_factor(),
                 "KAFKA_CONFLUENT_CLUSTER_LINK_ENABLE": self.replication_factor() >= 3,
                 "KAFKA_CONFLUENT_REPORTERS_TELEMETRY_AUTO_ENABLE": self.replication_factor() >= 3,
+                "KAFKA_REPLICATION_FACTOR": self.replication_factor(),
+                "KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR": self.replication_factor(),              
             }
 
             controller_dict = {}