diff --git a/src/lib.rs b/src/lib.rs
index b66408e..6f96d9b 100644
--- 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");