fixup! Fix pulsar uri scheme

quickwit-oss · Oct 3, 2024 · 10a16d0 · 10a16d0
1 parent c5fab89
commit 10a16d0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/quickwit/quickwit-config/src/source_config/mod.rs b/quickwit/quickwit-config/src/source_config/mod.rs
@@ -28,6 +28,7 @@ use quickwit_common::is_false;
 use quickwit_common::uri::Uri;
 use quickwit_proto::metastore::SourceType;
 use quickwit_proto::types::SourceId;
+use regex::Regex;
 use serde::de::Error;
 use serde::{Deserialize, Deserializer, Serialize};
 use serde_json::Value as JsonValue;
@@ -498,7 +499,7 @@ pub enum PulsarSourceAuth {
 fn pulsar_uri<'de, D>(deserializer: D) -> Result<String, D::Error>
 where D: Deserializer<'de> {
     let uri: String = Deserialize::deserialize(deserializer)?;
-    let re: Regex = Regex::new(r"pulsar(\+ssl)?://.*").unwrap();
+    let re: Regex = Regex::new(r"pulsar(\+ssl)?://.*").expect("regular expression should compile");
 
     if !re.is_match(uri.as_str()) {
         return Err(Error::custom(format!(