Kafka通過多種機制來防止未授權訪問,主要包括認證和授權兩個方面。以下是具體的配置步驟和注意事項:
啟用認證
server.properties
文件中,設置listeners=SASL_PLAINTEXT://hostname:9092
來啟用SASL認證。security.inter.broker.protocol=SASL_PLAINTEXT
來確保broker之間的通信也經過認證。配置用戶和密碼
kafka_server_jaas.conf
文件中配置用戶名和密碼,例如:KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret";
};
配置客戶端
kafka_client_jaas.conf
文件中配置相應的用戶名和密碼,例如:KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="alice"
password="alice-secret";
};
權限控制
通過上述配置,Kafka可以有效地防止未授權訪問,確保數據的安全傳輸和存儲。