Spring Kafka客户端SSL设置

Question

我的设置：

• JDK 11.0.6
• Spring护套2.2.4.释放
• Springkafka 2.4.1

我已经在PLAINTEXT中验证了我的Zookeeper/Kafka/client应用程序，一切正常。我还用Kafka客户端工具验证了我的密钥库/信任库。

我正在使用KafkaAdmin bean配置我的主题，它似乎在SSL连接上失败了:

@Bean
public KafkaAdmin kafkaAdmin() {
    Map<String, Object> configs = new HashMap<>();
    configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, getKafkaHost());
    configs.put("security.protocol", "SSL");
    configs.put("ssl.key.password", "xxx");
    configs.put("ssl.keystore.location", "/keystore/client.keystore.jks");
    configs.put("ssl.keystore.password", "xxx");
    configs.put("ssl.truststore.location", "/keystore/kafka.truststore.jks");
    configs.put("ssl.truststore.password", "xxx");
    return new KafkaAdmin(configs);
}

我的两个JKS文件位于项目的src/main/resources/keystore中。< code>/keystore不起作用...如果我指定< code >/src/main/resources/keystore/client . keystore . jks ，它们似乎会被选中...这在现实世界中行得通吗？在独立的tomcat中运行时，会有一个< code >/src/main/resources/keystore ？

根据我的理解，路径是相对于target/classes文件夹的，不是吗？

Answer 1

Kafka 客户端或 Spring 无法解析直接随路径提供的 .jks 文件，即使您提供了绝对路径也是如此。提供像 src/main/resources/keystore 这样的相对路径不是一个好主意，因为在构建之后，您的资源目录内容将直接复制到目标/类中，如您所知。

因此，使用classpath中的值注释将文件直接绑定到org.springframework.core.io.Resource类型实例。

@Value("classpath:certs/keystore/kafka.keystore.jks")
private Resource keystore;

@Value("classpath:certs/truststore/kafka.truststore.jks")
private Resource truststore;

然后像这样从那个实例中得到绝对路径；

configs.put("ssl.keystore.location", keystore.getFile().getAbsolutePath());
configs.put("ssl.truststore.location", truststore.getFile().getAbsolutePath());

如您所见，密钥库和信任库文件应位于类路径中。在我的情况下，它们分别位于 src/资源/证书/密钥库和 src/资源/证书/信任库目录中。