fix: fixed bug where replication factor wasn't set

refs: #181
DataCater · Mar 23, 2023 · 5c8ca5a · 5c8ca5a
1 parent 322aed4
commit 5c8ca5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/platform-api/src/main/java/io/datacater/core/stream/KafkaStreamsAdmin.java b/platform-api/src/main/java/io/datacater/core/stream/KafkaStreamsAdmin.java
@@ -105,7 +105,7 @@ private static int getPartitions(Map<String, Object> topicConfig) {
 
   private static Short getReplicationFactor(Map<String, Object> topicConfig) {
     if (topicConfig.get(REPLICATION_FACTOR) instanceof String repFactor
-        && !topicConfig.get(PARTITION_COUNT).toString().isEmpty()) {
+        && !topicConfig.get(REPLICATION_FACTOR).toString().isEmpty()) {
       return Short.valueOf(repFactor);
     }
     return DEFAULT_REPLICATION_FACTOR;