0

我在AWS EKS上有一个Lucidworks Fusion 5 kubernetes安装设置，目前其中一项服务Connector Classic REST service出现中断。在深入研究日志后，我发现：

ERROR in com.lucidworks.logging.logback.PulsarAppender[PULSAR] - Failed to connect to Pulsar topic persistent://uat/_logs/system_logs at: pulsar://uat-pulsar-broker:6650 org.apache.pulsar.client.api.PulsarClientException$ProducerBlockedQuotaExceededError: Cannot create producer on topic with backlog quota exceeded

从这里我查看了pulsar-broker configmap 并发现：

backlogQuotaDefaultLimitGB: "10"

我不太精通Apache Pulsar，但在我看来，如果我尝试提高此积压配额限制，它应该允许 连接器经典 REST 服务再次连接到代理，这应该使连接器经典 REST 服务恢复正常。这是一个公平的评价吗？

  • 在不更改任何配置的情况下，是否有办法解决此问题（例如重新启动特定服务，...）？
  • 解决此问题的最佳方法是什么？

提前致谢。

4

1 回答 1

0

为了解决这个问题，我按照以下步骤操作：

  1. 进入 pulsar-broker pod

  2. 将目录更改为/pulsar/bin目录

  3. 使用 pulsar-admin CLI 查找需要清除的订阅

    ./pulsar-admin topics subscriptions <topic>

  4. 使用以下命令清除积压

    ./pulsar-admin topics clear-backlog <topic> -s <subscription>

  5. 脱壳并删除Connector Classic REST pod

  6. 几分钟后服务恢复

于 2022-01-10T17:08:39.843 回答