访问SSL安全的kafka代理/集群时所需的Java生产者/消费者Kafka客户端属性？

Question

当我们连接到Kafka集群/kafka时，在java客户机中我们定义了某些属性-

示例生产者属性

 Properties props = new Properties();
 props.put("bootstrap.servers", "localhost:9092");
 props.put("acks", "all");
 props.put("retries", 0);
 props.put("batch.size", 16384);
 props.put("linger.ms", 1);
 props.put("buffer.memory", 33554432);
 props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
 props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

示例Consumer -

Properties props = new Properties();
props.setProperty("bootstrap.servers", "localhost:9092");
props.setProperty("group.id", "test");
props.setProperty("enable.auto.commit", "true");
props.setProperty("auto.commit.interval.ms", "1000");
props.setProperty("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.setProperty("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

类似地，当连接到使用SSL-Auth.保护的Kafka集群时，应该在此提及与SSL-Auth相关的任何属性(如keystore和信任存储路径等)。

有人能详细解释一下java客户端如何连接到安全的Kafka集群吗？

以上道具取自卡夫卡docs - 卡夫卡制片人 / 卡夫卡消费者。

Answer 1

卡夫卡文档中有一节详细介绍了如何配置SSL身份验证：ssl

在配置Kafka客户端部分中，它列出了所需的设置：

# For SSL
security.protocol=SSL
ssl.truststore.location=/var/private/ssl/client.truststore.jks
ssl.truststore.password=test1234

# For SSL auth
ssl.keystore.location=/var/private/ssl/client.keystore.jks
ssl.keystore.password=test1234
ssl.key.password=test1234