add plain

risingwavelabs · Sep 18, 2023 · a0b34e8 · a0b34e8
1 parent 1e25f4c
commit a0b34e8
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/connector/src/common.rs b/src/connector/src/common.rs
@@ -402,7 +402,12 @@ impl NatsCommon {
                     ));
                 }
             }
-            _ => {}
+            Some("plain") => {}
+            _ => {
+                return Err(anyhow_error!(
+                    "nats connect mode only accept user_and_password/credential/plain"
+                ));
+            }
         };
 
         let servers = self.server_url.split(',').collect::<Vec<&str>>();