如何在Debian上配置Kafka安全认证_运维文库_资讯中心

发布时间:2026-04-27 00:03:06

阅读量:2

在Debian上配置Apache Kafka的安全认证涉及多个步骤，包括设置SSL/TLS加密通信和配置SASL（简单认证和安全层）进行身份验证。以下是一个基本的指南，帮助你在Debian系统上配置Kafka的安全认证。

前提条件

安装Java：Kafka需要Java运行时环境。你可以使用以下命令安装OpenJDK：
```
sudo apt update
sudo apt install openjdk-11-jdk
```

下载并解压Kafka：从Apache Kafka官方网站下载最新版本的Kafka，并解压到你的服务器上。

wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0

配置SSL/TLS

生成SSL证书和密钥：

keytool -genkey -alias kafka-server -keystore kafka.server.keystore.jks -storepass password -validity 365 -keysize 2048
keytool -export -alias kafka-server -file kafka.server.cer -keystore kafka.server.keystore.jks -storepass password
keytool -import -alias kafka-server -file kafka.server.cer -keystore kafka.server.truststore.jks -storepass password

配置Kafka服务器：编辑config/server.properties文件，添加或修改以下配置：

listeners=SSL://:9093
ssl.keystore.location=/path/to/kafka.server.keystore.jks
ssl.keystore.password=password
ssl.key.password=password
ssl.truststore.location=/path/to/kafka.server.truststore.jks
ssl.truststore.password=password
ssl.enabled.protocols=TLSv1.2

配置Kafka客户端：编辑config/client.properties文件，添加或修改以下配置：

security.protocol=SSL
ssl.truststore.location=/path/to/kafka.server.truststore.jks
ssl.truststore.password=password
ssl.keystore.location=/path/to/client.keystore.jks
ssl.keystore.password=password
ssl.key.password=password

配置SASL

生成JAAS配置文件：创建一个JAAS配置文件（例如kafka_server_jaas.conf），内容如下：

KafkaServer {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="admin-secret"
    user_admin="/path/to/admin.properties";
};

创建用户属性文件：创建一个用户属性文件（例如admin.properties），内容如下：
```
password=admin-secret
```

配置Kafka服务器：编辑config/server.properties文件，添加或修改以下配置：

listeners=SASL_SSL://:9093
security.inter.broker.protocol=SASL_SSL
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=false
super.users=User:admin
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin-secret";

配置Kafka客户端：编辑config/client.properties文件，添加或修改以下配置：

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

启动Kafka服务器

确保所有配置都正确无误后，启动Kafka服务器：

bin/kafka-server-start.sh config/server.properties

启动Kafka客户端

使用配置好的客户端属性文件启动Kafka客户端：

bin/kafka-console-producer.sh --broker-list localhost:9093 --topic test --property security.protocol=SASL_SSL --property sasl.mechanism=PLAIN --property sasl.jaas.config="org.apache.kafka.common.security.plain.PlainLoginModule required username='admin' password='admin-secret';"

通过以上步骤，你应该能够在Debian上成功配置Kafka的安全认证。请根据你的具体需求调整配置文件中的路径和密码。

以上就是关于“如何在Debian上配置Kafka安全认证”的相关介绍，筋斗云是国内较早的云主机应用的服务商，拥有10余年行业经验，提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩，主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复；电子化备案，提交快速，专业团队7×24小时服务支持！

简单好用、高性价比云服务器租用链接：https://www.jindouyun.cn/product/cvm