fix(source/nats): add missing default attribute for vectors

risingwavelabs · Aug 27, 2024 · 6d6a6a1 · 6d6a6a1
1 parent e3a9d37
commit 6d6a6a1
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/src/connector/src/source/nats/mod.rs b/src/connector/src/source/nats/mod.rs
@@ -126,8 +126,11 @@ pub struct NatsPropertiesConsumer {
     #[serde(rename = "consumer.filter_subject")]
     pub filter_subject: Option<String>,
 
-    #[serde(rename = "consumer.filter_subjects")]
-    #[serde(deserialize_with = "deserialize_optional_string_seq_from_string")]
+    #[serde(
+        rename = "consumer.filter_subjects",
+        default,
+        deserialize_with = "deserialize_optional_string_seq_from_string"
+    )]
     pub filter_subjects: Option<Vec<String>>,
 
     #[serde(rename = "consumer.replay_policy")]
@@ -178,8 +181,11 @@ pub struct NatsPropertiesConsumer {
     #[serde_as(as = "Option<DisplayFromStr>")]
     pub memory_storage: Option<bool>,
 
-    #[serde(rename = "consumer.backoff.sec")]
-    #[serde(deserialize_with = "deserialize_optional_u64_seq_from_string")]
+    #[serde(
+        rename = "consumer.backoff.sec",
+        default,
+        deserialize_with = "deserialize_optional_u64_seq_from_string"
+    )]
     pub backoff: Option<Vec<u64>>,
 }