Kafka 连接 REST 的 500 个请求超时 API POST/PUT/DELETE

Question

我正在尝试使用 Kafka Connect REST API。

有时，我不断遇到 POST/PUT/DELETE API 的超时问题，例如部署新连接器或删除连接器（[= 没有超时问题17=]).

错误如下所示：

{
    "error_code": 500,
    "message": "Request timed out"
}

现在我的解决方案只是等待几个小时，希望它能再次起作用。有时又能用，有时又不行。

我找到了一个潜在的解决方案，如果我设置

KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1

它可能会根据 https://github.com/confluentinc/kafka-connect-elasticsearch/issues/75#issuecomment-386400308

进行修复

但是，主题复制默认为 3 HA，更改为 1 不好。

还有其他方法可以解决吗？

Answer 1

我发现只要重启 Kafka Connect，问题就会消失。

kubectl rollout restart deployment my-kafka-connect --namespace=my-kafka

到目前为止，超时问题没有再次出现。