Kafka Connect REST API POST/PUT/DELETE的500请求超时

Question

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

有时，我总是遇到＜code>POST＜/code>/＜code>PUT＜/code>/＜code>DELETE＜/code＞API的超时问题，例如部署新的连接器或删除连接器（＜code>GET＜/code＞没有超时问题）。

错误如下所示：

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

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

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

KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1

根据https://github . com/confluent Inc/Kafka-connect-elastic search/issues/75 # issue comment-386400308，它可能会修复

但是，对于HA，主题复制默认为3，因此不宜更改为1。

还有别的办法可以修吗

Answer 1

我没有等待，而是找到了一种变通方法，只需重新启动Kafka Connect，问题就会消失。

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

到目前为止，超时问题还没有再次出现。不确定根本问题。