apache-kafka - KafkaConnect Rest API 基本身份验证问题

Question

我们目前正在使用 Kafka 版本 2.11 和 KafakConnect 2.0.0，这是我们获得的 hortonworks 发行版的一部分。我们通过在 connect.distributed.properties 中添加这个来启用 Rest API 基本身份验证

listeners=https://${hostname}:${restPort}

并遵循此处提到的所有步骤。

现在一切正常，我们可以在领导节点上的所有 GET 和 POST 操作中使用基本身份验证，而只有 GET 操作在工作节点上工作。当我们尝试在工作节点上执行 POST 操作时，我们会收到此错误 -

{"error_code":500,"message":"IO Error trying to forward REST request: org.eclipse.jetty.client.HttpResponseException: HTTP protocol violation: Authentication challenge without WWW-Authenticate header"}

根据消息，很明显工作人员正在尝试将 POST/DELETE 请求转发给领导者，但没有这样做。失败的示例 DELETE 请求如下所示：

curl -X DELETE -i -H 'Accept:application/json' -H 'Authorization:Basic base64encodedpassword' https://hostname:18084/connectors/someconnector

如果有人以前遇到过这个问题，请提供帮助。我的休息请求的形成可能有问题，但在集群领导者上执行时它工作正常......谢谢

标签： apache-kafkaapache-kafka-connect