Spring Boot中Kafka加密属性解密后仍失效的问题求助

问题根源 #

你当前的代码是将解密后的值存入systemProperties，但命令行参数的优先级高于systemProperties，Kafka初始化时会优先读取命令行传入的加密值，导致解密逻辑未生效。

解决方法 #

修改DecoderEnvironmentPostProcessor，通过添加高优先级的PropertySource来覆盖原有加密属性，确保Kafka读取到解密后的值。

修改后的代码：

public class DecoderEnvironmentPostProcessor implements EnvironmentPostProcessor {

    private static final List<String> ENCODED_PROPERTIES = List.of(
        "spring.kafka.bootstrap-servers",
        "spring.kafka.properties.ssl.keystore.password",
        "spring.kafka.properties.ssl.truststore.password"
    );
    
    @Override
    public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) {
        Map<String, Object> decryptedProps = new HashMap<>();
        for (String propKey : ENCODED_PROPERTIES) {
            String encryptedValue = environment.getProperty(propKey);
            if (encryptedValue != null) {
                try {
                    String decryptedValue = myDecrypt(encryptedValue);
                    decryptedProps.put(propKey, decryptedValue);
                } catch (Exception e) {
                    // 不要忽略异常，直接抛出避免无效配置启动
                    throw new RuntimeException("Failed to decrypt property: " + propKey, e);
                }
            }
        }
        // 添加高优先级PropertySource，确保优先读取解密后的值
        environment.getPropertySources().addFirst(
            new MapPropertySource("decryptedKafkaProps", decryptedProps)
        );
    }
}

关键说明 #

1. 优先级覆盖：通过addFirst方法将解密后的属性放入最优先的PropertySource，会覆盖命令行、配置文件等来源的同名属性
2. 异常处理优化：移除空的TODO，抛出异常防止应用带着无效加密配置启动
3. 代码简化：用List.of替代ArrayList匿名内部类，更简洁高效

额外检查 #

确保spring.factories配置正确：

org.springframework.boot.env.EnvironmentPostProcessor=com.your.package.DecoderEnvironmentPostProcessor

内容的提问来源于stack exchange，提问作者Hytobi