无法为Kafka Connect REST API配置SSL

Question

我正在尝试为Kafka Connect REST API（2.11-2.1.0）配置SSL。

问题所在

我尝试了两种配置（工人配置）：

• 带有侦听器.https.前缀

listeners=https://localhost:9000
listeners.https.ssl.keystore.location=/mypath/keystore.jks
listeners.https.ssl.keystore.password=mypassword
listeners.https.ssl.key.password=mypassword

< li >并且不带< code>listeners.https.前缀

listeners=https://localhost:9000
ssl.keystore.location=/mypath/keystore.jks
ssl.keystore.password=mypassword
ssl.key.password=mypassword

两种配置都启动正常，并在尝试连接到https://localhost:9000时显示以下异常：

javax.net.ssl.SSLHandshakeException: no cipher suites in common

在日志中，我看到SslContextWorks是使用任何密钥库创建的，但使用密码：

210824 ssl.SslContextFactory:350 DEBUG: Selected Protocols [TLSv1.2, TLSv1.1, TLSv1] of [SSLv2Hello, SSLv3, TLSv1, TLSv1.1, TLSv1.2]
210824 ssl.SslContextFactory:351 DEBUG: Selected Ciphers   [TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384, TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384, TLS_ECDH_ECDSA_WITH_AES_256_CBC_SHA384, TLS_ECDH_RSA_WITH_AES_256_CBC_SHA384, TLS_DHE_RSA_WITH_AES_256_CBC_SHA256, ...]
210824 component.AbstractLifeCycle:177 DEBUG: STARTED @10431ms SslContextFactory@42f8285e[provider=null,keyStore=null,trustStore=null]

因为我知道密钥库中的密码是绝对正确的，所以我深入研究了源代码，并开始调试。

最后，我发现无论是纯 ssl.* 还是前缀 listeners.https.ssl.* 配置都没有被考虑在内，事实证明目前不可能为 Kafka Connect REST API 配置 SSL。

调用顺序为：

1. RestServer。创建连接器
2. SSLU瓷砖。createSslContext工厂
3. AbstractConfig.values WithPrefixAll或Nothing

最后一种方法是麻烦的原因。

如果我们有 listeners.https. 属性，则无法返回它们，因为它们在第 254 行过滤掉（因为 WorkerConfig 不包含带前缀的属性）。

否则，如果我们有无前缀的< code>ssl。属性，它们也不会返回，因为< code>values字段只包含来自同一WorkerConfig的已知属性(< code>values是ConfigDef.parse的结果)。

我是否遗漏了什么，是否有人成功为kafka连接rest api配置了SSL？

Answer 1

我还没有测试Connect REST API，但KafkaTemplate使用ssl发送和接收消息。从您的配置中，我可能会假设两个问题：

• 您没有指定信任库（用于证书链检查）
• 您使用了绝对路径，但springkeystore位置解释为相对于/webapp的
  

我尝试从示例测试应用程序：https://memorynotfound.com/spring-kafka-and-spring-boot-configuration-example/和https://gist.github.com/itzg/e3ebfd7aec220bf0522e23a65b1296c8

测试了2.0.4.RELEASE，使用了kafka库

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

这是我的应用程序。属性内容:

spring.application.name=my-stream-app
spring.kafka.bootstrap-servers=localhost:9093
spring.kafka.ssl.truststore-location=kafka.server.truststore.jks
spring.kafka.ssl.truststore-password=123456 
spring.kafka.ssl.keystore-location=kafka.server.keystore.jks
spring.kafka.ssl.keystore-password=123456 
spring.kafka.ssl.key-password=123456
spring.kafka.properties.security.protocol=SSL

spring.kafka.consumer.group-id=properties test-consumer-group        
app.topic.foo=test 

Kafka 服务器配置片段：

listeners=SSL://localhost:9093

ssl.truststore.location=/home/legioner/kafka.server.truststore.jks
ssl.truststore.password=123456
ssl.keystore.location=/home/legioner/kafka.server.keystore.jks
ssl.keystore.password=123456
ssl.key.password=123456

Answer 2

尝试导出KAFKA_OPTS=-Djava.security.auth.login.config=/apps/KAFKA/conf/KAFKA/kf_jaas。conf其中kf_jaas。conf包含ZooKeeper客户端身份验证