在发布结果之前处理所有消息
Process all messages before posting result
我正在做一个 kaafka 任务，任务是给定 seasons/rounds/game 由玩家生成随机消息。
有一个消费者会收听所有这些消息并将跟踪评分逻辑。评分完成后，它将把分数发布到最终主题。
现在让我感到困惑的问题是我的分数计算器如何知道在发布最终分数之前已经收到了玩家的所有分数？
这就是无限数据的乐趣……它是无限的:-)
也就是没有真正收到"all data"的概念
您需要在您的应用程序中构建某种逻辑，该逻辑要么在一定时间后决定在没有更多数据的情况下完成，要么发出数据的应用程序发送某种 "end of feed" message/watermark表示可以处理消费者已经阅读的内容。
我正在做一个 kaafka 任务，任务是给定 seasons/rounds/game 由玩家生成随机消息。
有一个消费者会收听所有这些消息并将跟踪评分逻辑。评分完成后，它将把分数发布到最终主题。
现在让我感到困惑的问题是我的分数计算器如何知道在发布最终分数之前已经收到了玩家的所有分数？
这就是无限数据的乐趣……它是无限的:-) 也就是没有真正收到"all data"的概念
您需要在您的应用程序中构建某种逻辑，该逻辑要么在一定时间后决定在没有更多数据的情况下完成，要么发出数据的应用程序发送某种 "end of feed" message/watermark表示可以处理消费者已经阅读的内容。