diff --git a/kafka_consumer/datadog_checks/kafka_consumer/config.py b/kafka_consumer/datadog_checks/kafka_consumer/config.py index c9bfe10bfd2dd..a82ffce56ffca 100644 --- a/kafka_consumer/datadog_checks/kafka_consumer/config.py +++ b/kafka_consumer/datadog_checks/kafka_consumer/config.py @@ -72,6 +72,13 @@ def __init__(self, init_config, instance, log) -> None: else: self._tls_verify = "true" if is_affirmative(instance.get("tls_verify", True)) else "false" + if ( + not self._tls_ca_cert + and os.name != 'nt' + and os.path.exists('/opt/datadog-agent/embedded/ssl/certs/cacert.pem') + ): + self._tls_ca_cert = '/opt/datadog-agent/embedded/ssl/certs/cacert.pem' + def validate_config(self): if not self._kafka_connect_str: raise ConfigurationError('`kafka_connect_str` is required')