我有一个使用 KCL 开发的消费者应用程序。应用程序为每个流创建一个Worker，并且每个流都有多个分片。在不同的执行中，应用程序采用不同数量的分片，并且不会占用所有分片。我只运行一个应用程序实例，我希望消耗所有分片。哪里可能有问题，所以我可以寻找解决它？
谢谢
问问题
147 次
1 回答
0
截至目前，对于 V.1 和 V.2，KCL 对每个流都有效，并且不可能通过一个 KCL 应用程序消耗多个流。有一个开放票可以在同一个 JVM 上运行多个实例。请查看KCL Github对话以获取更多信息
于 2018-09-21T20:13:23.313 回答