我正在做一个kaafka任务，任务是由玩家为给定的季节/回合/游戏生成随机消息。有一个消费者会监听所有这些消息并跟踪评分逻辑。评分完成后，它会将评分发布到最后一个主题。现在我搞不懂的问题是，我的分数计算器怎么知道在公布最终分数之前，所有玩家的分数都已经收到了？
rkue9o1l1#
这就是无界数据的乐趣…它是无界的：-）也就是说，实际上并没有“所有数据”都被接收的概念。您需要在应用程序中构建某种逻辑，要么在一段时间后不再有数据的情况下决定它是否完成，要么发送数据的应用程序发送某种“提要结束”消息/水印，以指示可以处理使用者读取的内容。
1条答案
按热度按时间rkue9o1l1#
这就是无界数据的乐趣…它是无界的：-）也就是说，实际上并没有“所有数据”都被接收的概念。
您需要在应用程序中构建某种逻辑，要么在一段时间后不再有数据的情况下决定它是否完成，要么发送数据的应用程序发送某种“提要结束”消息/水印，以指示可以处理使用者读取的内容。