fix: set replication_factor properly

GreptimeTeam · Dec 26, 2023 · e976402 · e976402
1 parent 0e6fd8b
commit e976402
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/common/config/src/wal/kafka.rs b/src/common/config/src/wal/kafka.rs
@@ -121,13 +121,16 @@ pub struct StandaloneKafkaConfig {
 
 impl Default for StandaloneKafkaConfig {
     fn default() -> Self {
+        let base = KafkaConfig::default();
+        let replication_factor = base.broker_endpoints.len() as i16;
+
         Self {
-            base: KafkaConfig::default(),
+            base,
             num_topics: 64,
             selector_type: TopicSelectorType::RoundRobin,
             topic_name_prefix: "greptimedb_wal_topic".to_string(),
             num_partitions: 1,
-            replication_factor: 3,
+            replication_factor,
             create_topic_timeout: Duration::from_secs(30),
         }
     }

diff --git a/src/common/meta/src/wal.rs b/src/common/meta/src/wal.rs
@@ -89,7 +89,7 @@ mod tests {
             selector_type = "round_robin"
             topic_name_prefix = "greptimedb_wal_topic"
             num_partitions = 1
-            replication_factor = 3
+            replication_factor = 1
             create_topic_timeout = "30s"
             backoff_init = "500ms"
             backoff_max = "10s"
@@ -103,7 +103,7 @@ mod tests {
             selector_type: TopicSelectorType::RoundRobin,
             topic_name_prefix: "greptimedb_wal_topic".to_string(),
             num_partitions: 1,
-            replication_factor: 3,
+            replication_factor: 1,
             create_topic_timeout: Duration::from_secs(30),
             backoff: KafkaBackoffConfig {
                 init: Duration::from_millis(500),