Kafka connection with a CA certificate

airyhq / airy

💬 Open Source App Framework to build streaming apps with real-time data - 💎 Build real-time data pipelines and make real-time data universally accessible - 🤖 Join historical and real-time data in the stream to create smarter ML and AI applications. - ⚡ Standardize complex data ingestion and stream data to apps with pre-built connectors

https://airy.co/docs/core

Apache License 2.0

366 stars 45 forks source link

Kafka connection with a CA certificate #4167

Open ljupcovangelski opened 2 months ago

ljupcovangelski commented 2 months ago

We need to add the possibility to connect Airy to a Kafka cluster which authenticates with a CA certificate.

The certificate needs to be present on the running workloads, along with the configured sasl.username and sasl.password. This is a sample configuration:

security.protocol=SASL_SSL
sasl.mechanisms=PLAIN
sasl.username=user
sasl.password=pass
ssl.ca.location=/tmp/ca.pem