diff --git a/metadata-service/configuration/src/main/java/com/linkedin/metadata/config/kafka/TopicsConfiguration.java b/metadata-service/configuration/src/main/java/com/linkedin/metadata/config/kafka/TopicsConfiguration.java index 43d97c9c76..afb990da01 100644 --- a/metadata-service/configuration/src/main/java/com/linkedin/metadata/config/kafka/TopicsConfiguration.java +++ b/metadata-service/configuration/src/main/java/com/linkedin/metadata/config/kafka/TopicsConfiguration.java @@ -69,7 +69,7 @@ public class TopicsConfiguration { public static class TopicConfiguration { private String name; private Integer partitions; - private Integer replicationFactor = 1; + private Integer replicationFactor; private Map configProperties; private Boolean enabled = true; // Default to true if not specified }