问题描述
使用 KCL 开发了一个 java 应用程序。我有一个 Kinesis Listener 用于包含 3 个分片的流。但是，当工作程序启动时，它会给出一条消息，表明它仅在分片上使用。
不知道为什么没有使用其他分片。
有趣的是，这些消息的生产者似乎能够向所有分片发送消息。 最终的结果是，无法使用生成到其他分片的消息。
这是因为其他两个分片的租约到期吗？ 有没有办法检查这个（没有编写租赁管理的自定义逻辑） 只需依靠此处的默认逻辑进行租赁管理。
这已经工作了一段时间，并且在 kubernetes pod 由于某种原因重新启动时停止工作。真的在寻找如何调试这个问题
谢谢指点
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）