我有一个 Java 使用者（KCL 实现）来使用来自 1 个带有 2 个分片的 Kinesis 流的消息。
KCL 创建 2 个与每个分片相关的 RecordProcessor。
然后我让我的机器进入睡眠状态，所以 JVM 暂停了。唤醒时，KCL 库在原来的 2 个 RecordProcessor 之外创建 2 个额外的 RecordProcessor。因此，对于每个分片，有 2 个处理器会导致冲突。
预期的行为是在原始 RecordProcessor 仍然存在时不生成 2 个新 RecordProcessor。KCL 中处理生成新 RecordProcessor 的逻辑的代码在哪里？