时间戳

首页 > 解决方案 > 我们如何为 kafka 连接服务启用身份验证？

apache-kafka - 我们如何为 kafka 连接服务启用身份验证？

问题描述

我在本地使用这个 docker-compose.yml 文件来设置 confluent-platform。[https://github.com/confluentinc/cp-all-in-one/blob/6.2.0-post/cp-all-in-one/docker-compose.yml]

我们在 8083 端口使用连接服务从外部源系统中提取数据。

现在的要求是访问这个 Kafka-connect 服务 8083 端口，我们需要启用一些身份验证（Basic，SSl ....）

但是我们的 kafka 集群没有身份验证，它只是开放的。

我们只需要在连接服务中启用身份验证。

我试图在 docker-compose 中添加以下行

CONNECT_REST_EXTENSION_CLASS : org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension
KAFKA_OPTS: -Djava.security.auth.login.config=/opt/kafka/secrets/connect_jaas.conf

我的 connect_jaas.conf

KafkaConnect {
   org.apache.kafka.connect.rest.basic.auth.extension.PropertyFileLoginModule required
             file="/opt/kafka/secrets/rest-credentials.password";
};

rest-credentials.password

random=pass123

但是上面的配置是不行的……！！！

有可能实现上述场景吗？

如果是的话，谁能让我知道如何实现同样的目标？

标签： apache-kafkaapache-kafka-connectconfluent-platform

解决方案

推荐阅读