Kafka brokers supports client authentication via SASL. export KAFKA_OPTS="- Djava.security.auth.login.config=/etc/kafka/kafka_server_jaas.conf" .