spring-kafka-ssl类路径信任库

Question

例如，如何使用spring-kafka（不带sboot）进行SSL配置，使用相对/类路径指定信任库的位置？

仅当提供了绝对路径时，它才起作用。

令人惊讶的是，当使用Spring引导运行时，它可以使用相对路径（在jar内）。。

Answer 1

我对此的补丁是在Spring启动时将密钥库复制到文件系统。（而不是来自 KafkaAuto 配置的消费者工厂，而是拥有自己的消费者工厂）

1. 从属性中获取密钥库的名称（因此密钥库可以在 DEV/INT/PROD 阶段中以不同的方式命名）
2. 将其复制到 k8n pod 的文件系统中（如果在 Windows 上本地运行，请使用与“/tmp”不同的目标）
3. 使用文件系统中的新位置更新 Kafka 属性。

    @Configuration
    @RequiredArgsConstructor
    public class KafkaConfig {
    
        private final KafkaProperties kafkaProps;
    
        @Bean
        @ConditionalOnProperty(value = "spring.kafka.enabled", havingValue = "true")
        public ConsumerFactory<?, ?> consumerFactory() throws IOException {
            Path fileSystemKeyStorePath = Paths.get("/tmp", "keystore.pfx");
    
            Resource keyStoreLocationFromProperties = kafkaProps.getSsl().getKeyStoreLocation();
            Files.copy(keyStoreLocationFromProperties.getInputStream(),
                fileSystemKeyStorePath, StandardCopyOption.REPLACE_EXISTING);
    
            Ssl ssl = kafkaProps.getSsl();
            ssl.setKeyStoreLocation(new FileSystemResource(fileSystemKeyStorePath));
    
            return new DefaultKafkaConsumerFactory(kafkaProps.buildConsumerProperties());
        }
    }

Answer 2

该文件由Kafka读取，而不是斯普林。

Kafka对Spring的类路径资源抽象一无所知。

我认为你对靴子的看法是错误的；只有在罐子爆炸的情况下才有效。boot在< code > kafk properties 中有以下代码...

    map.from(this::getTrustStoreLocation).as(this::resourceToPath)
            .to(properties.in(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG));

...

private String resourceToPath(Resource resource) {
    try {
        return resource.getFile().getAbsolutePath();
    }
    catch (IOException ex) {
        throw new IllegalStateException(
                "Resource '" + resource + "' must be on a file system", ex);
    }
}

要在jar中使用信任库，您需要在启动应用程序上下文之前，首先将其复制到文件系统(例如< code>/tmp)。