From e713af5b48645501858ce7abac0f43f99e120bcf Mon Sep 17 00:00:00 2001
From: tabVersion <tabvision@bupt.icu>
Date: Fri, 9 Feb 2024 16:30:03 +0800
Subject: [PATCH] add props enable.ssl.certificate.verification

---
 src/connector/src/common.rs | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/connector/src/common.rs b/src/connector/src/common.rs
index 88f6c9f9ea313..418155250e74e 100644
--- 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());
+        }
     }
 }