add props enable.ssl.certificate.verification

risingwavelabs · Feb 9, 2024 · e713af5 · e713af5
1 parent d2c547a
commit e713af5
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/connector/src/common.rs b/src/connector/src/common.rs
@@ -259,6 +259,10 @@ pub struct RdKafkaPropertiesCommon {
     #[serde(rename = "properties.client.id")]
     #[serde_as(as = "Option<DisplayFromStr>")]
     pub client_id: Option<String>,
+
+    #[serde(rename = "properties.enable.ssl.certificate.verification")]
+    #[serde_as(as = "Option<DisplayFromStr>")]
+    pub enable_ssl_certificate_verification: Option<bool>,
 }
 
 impl RdKafkaPropertiesCommon {
@@ -275,6 +279,9 @@ impl RdKafkaPropertiesCommon {
         if let Some(v) = self.client_id.as_ref() {
             c.set("client.id", v);
         }
+        if let Some(v) = self.enable_ssl_certificate_verification {
+            c.set("enable.ssl.certificate.verification", v.to_string());
+        }
     }
 }