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