如何為Linux Kafka配置SSL

為Linux Kafka配置SSL可以確保數據在傳輸過程中的安全性。以下是詳細的步驟指南：

1. 生成SSL證書和密鑰

首先，你需要生成SSL證書和密鑰?？梢允褂肙penSSL工具來完成這一任務。

生成CA證書

openssl req -new -x509 -days 365 -nodes -out ca.crt -keyout ca.key

生成服務器證書和密鑰

openssl req -new -nodes -out server.crt -keyout server.key -subj "/CN=kafka-server"

在提示輸入信息時，確保Common Name (CN)設置為你的Kafka服務器的主機名或IP地址。

生成客戶端證書和密鑰

openssl req -new -nodes -out client.crt -keyout client.key -subj "/CN=kafka-client"

2. 配置Kafka服務器

編輯Kafka服務器的配置文件server.properties，通常位于/etc/kafka/目錄下。

# 啟用SSL
listeners=SSL://:9093
advertised.listeners=SSL://your_kafka_server_hostname:9093

# SSL配置
ssl.keystore.location=/path/to/server.jks
ssl.keystore.password=your_keystore_password
ssl.key.password=your_key_password
ssl.truststore.location=/path/to/truststore.jks
ssl.truststore.password=your_truststore_password

# 啟用SSL協議
ssl.enabled.protocols=TLSv1.2,TLSv1.3

# 啟用SSL密碼套件
ssl.cipher.suites=TLS_AES_128_GCM_SHA256,TLS_AES_256_GCM_SHA384

3. 創建Java KeyStore和TrustStore

將生成的證書和密鑰導入到Java KeyStore和TrustStore中。

創建KeyStore

keytool -importkeystore -deststorepass your_keystore_password -destkeypass your_key_password -destkeystore server.jks -srckeystore server.crt -srcstoretype PEM -alias kafka-server

創建TrustStore

keytool -importkeystore -deststorepass your_truststore_password -destkeystore truststore.jks -srckeystore ca.crt -srcstoretype PEM -alias ca

4. 配置Kafka客戶端

編輯Kafka客戶端的配置文件client.properties，通常位于/etc/kafka/目錄下。

# 啟用SSL
security.protocol=SSL

# SSL配置
ssl.truststore.location=/path/to/truststore.jks
ssl.truststore.password=your_truststore_password
ssl.keystore.location=/path/to/client.jks
ssl.keystore.password=your_keystore_password

# 啟用SSL協議
ssl.enabled.protocols=TLSv1.2,TLSv1.3

# 啟用SSL密碼套件
ssl.cipher.suites=TLS_AES_128_GCM_SHA256,TLS_AES_256_GCM_SHA384

5. 重啟Kafka服務器

完成上述配置后，重啟Kafka服務器以應用更改。

sudo systemctl restart kafka

6. 驗證SSL連接

你可以使用Kafka自帶的工具來驗證SSL連接是否成功。

創建一個生產者和消費者

kafka-console-producer --broker-list your_kafka_server_hostname:9093 --topic test --property security.protocol=SSL --property ssl.truststore.location=/path/to/truststore.jks --property ssl.truststore.password=your_truststore_password --property ssl.keystore.location=/path/to/client.jks --property ssl.keystore.password=your_keystore_password

kafka-console-consumer --bootstrap-server your_kafka_server_hostname:9093 --topic test --property security.protocol=SSL --property ssl.truststore.location=/path/to/truststore.jks --property ssl.truststore.password=your_truststore_password --property ssl.keystore.location=/path/to/client.jks --property ssl.keystore.password=your_keystore_password

通過以上步驟，你應該能夠成功為Linux Kafka配置SSL，并確保數據傳輸的安全性。