如何为Ubuntu Kafka配置SSL加密 - 问答

为Ubuntu Kafka配置SSL加密可以确保数据在传输过程中的安全性。以下是详细的步骤指南：

1. 生成SSL证书和密钥

首先，你需要生成SSL证书和密钥。可以使用OpenSSL工具来完成这一任务。

生成CA证书

mkdir kafka_ssl
cd kafka_ssl
openssl genrsa -des3 -out ca-key.pem 4096
openssl req -new -x509 -days 3650 -key ca-key.pem -out ca-cert.pem -subj "/C=US/ST=State/L=City/O=Organization/CN=KafkaCA"

生成服务器证书和密钥

openssl genrsa -des3 -out server-key.pem 2048
openssl req -new -key server-key.pem -out server-req.pem -subj "/C=US/ST=State/L=City/O=Organization/CN=kafka-server"
openssl x509 -req -days 365 -in server-req.pem -CA ca-cert.pem -CAkey ca-key.pem -set_serial 01 -out server-cert.pem

生成客户端证书和密钥

openssl genrsa -des3 -out client-key.pem 2048
openssl req -new -key client-key.pem -out client-req.pem -subj "/C=US/ST=State/L=City/O=Organization/CN=kafka-client"
openssl x509 -req -days 365 -in client-req.pem -CA ca-cert.pem -CAkey ca-key.pem -set_serial 02 -out client-cert.pem

2. 配置Kafka服务器

编辑Kafka服务器的配置文件server.properties，通常位于/etc/kafka/server.properties。

# 启用SSL
listeners=SSL://:9093
advertised.listeners=SSL://your_server_ip:9093

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

# 启用SSL协议
ssl.protocol=TLSv1.2

# 启用SASL_SSL
sasl.enabled.mechanisms=PLAIN
security.inter.broker.protocol=SASL_SSL
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin-secret";

3. 创建Java KeyStore和TrustStore

使用keytool工具创建Java KeyStore和TrustStore。

创建KeyStore

keytool -import -alias kafka-server -file server-cert.pem -keystore server-keystore.jks -storepass your_keystore_password -storetype JKS

创建TrustStore

keytool -import -alias kafka-ca -file ca-cert.pem -keystore server-truststore.jks -storepass your_truststore_password -storetype JKS

4. 配置Kafka客户端

编辑Kafka客户端的配置文件client.properties，通常位于/etc/kafka/client.properties。

# 启用SSL
security.protocol=SSL

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

# 启用SASL_SSL
sasl.mechanism=PLAIN
security.inter.broker.protocol=SASL_SSL
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin-secret";

5. 重启Kafka服务器

完成配置后，重启Kafka服务器以应用更改。

sudo systemctl restart kafka

6. 验证SSL连接

使用Kafka客户端工具验证SSL连接是否成功。

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

通过以上步骤，你应该能够成功为Ubuntu Kafka配置SSL加密。确保所有路径和密码都正确无误，并且防火墙允许相应的端口通信。

0 赞

0 踩