chore: add truststore certificate as env variable

delta-io · Jul 3, 2024 · a1990e6 · a1990e6
1 parent b44b5b8
commit a1990e6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -1282,6 +1282,9 @@ fn kafka_client_config_from_options(opts: &IngestOptions) -> ClientConfig {
     if let Ok(key_pem) = std::env::var("KAFKA_DELTA_INGEST_KEY") {
         kafka_client_config.set("ssl.key.pem", key_pem);
     }
+    if let Ok(ca_pem) = std::env::var("KAFKA_DELTA_INGEST_CA") {
+        kafka_client_config.set("ssl.ca.pem", ca_pem);
+    }
     if let Ok(scram_json) = std::env::var("KAFKA_DELTA_INGEST_SCRAM_JSON") {
         let value: Value = serde_json::from_str(scram_json.as_str())
             .expect("KAFKA_DELTA_INGEST_SCRAM_JSON should be valid JSON");