gpt4 book ai didi

amazon-kinesis - IRecordsProcessor processRecords 未被 KCL 库调用

转载 作者:行者123 更新时间:2023-12-04 17:56:38 25 4
gpt4 key购买 nike

我们多次执行以下测试,但我们很难找到合理的解释来解释为什么会发生这种情况:

  • 我们创建一个消费者,我们等待它准备好
  • 我们在消费者正在收听的流中发布两条记录

我们只有一个分片,有时消费者不会收到记录通知。我们使用不同的 workerId,但具有相同 ApplicationName 的应用程序可能会窃取记录。

KCL 消费者从未获得刚刚发布的记录的原因是什么?

最佳答案

我的代码的问题是,一旦您在 KCL 中首次创建应用程序,用于 Dynamo 中检查点的匹配条目将存储分片迭代器的最后位置。

当您重新启动应用程序时,分片迭代器可能会比当前时间滞后很多,并且在您到达发布记录的当前位置之前可能需要很多次迭代。

因此,出于测试目的,您可能需要每次都创建一个新应用并每晚清洁发电机表

关于amazon-kinesis - IRecordsProcessor processRecords 未被 KCL 库调用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40002222/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com