在 Debian 上配置 Kafka 的安全性通常涉及以下几个关键步骤:
security.protocol 为 sasl_plaintext 或 sasl_ssl 来启用 SASL 认证。然后,需要配置 sasl.mechanism,例如 plain 或 scram-sha-256。props.put("bootstrap.servers","localhost:9092");
props.put("group.id","test");
props.put("security.protocol","sasl_plaintext");
props.put("sasl.mechanism","plain");
security.protocol 为 ssl,并提供 ssl.truststore.location 和 ssl.truststore.password。props.put("bootstrap.servers","localhost:9092");
props.put("group.id","test");
props.put("security.protocol","ssl");
props.put("ssl.truststore.location","/path/to/truststore/file");
props.put("ssl.truststore.password","password");
kafka-configs 命令行工具来创建和管理 SCRAM 证书和配置。请注意,具体的配置步骤可能会根据 Kafka 的版本和具体需求有所不同。建议参考 Kafka 的官方文档和配置指南来进行详细的配置。