- Change Kafka config
- Add
SECURITY_PROTOCOL
to environment variable instead of hard fixed
- Using config from env variables for SSL connection (Kafka SSL client)
KAFKA_SSL_CA_LOCATION=./ca.crt
# For SSL client
KAFKA_SSL_CERTIFICATE_LOCATION=./user.crt [./user.pem]
KAFKA_SSL_KEY_LOCATION=./user.key
KAFKA_SSL_KEY_PASSWORD=SOME_PASSWORD
For more information Using SSL with librdkafka
- Using config from env variables for declare Kafka brokers
KAFKA_BROKERS
- First launch 🚀🚀🚀