Обработайте все сообщения перед публикацией результата - PullRequest
0 голосов
/ 13 июня 2018

Я выполняю задание каафки, и задача состоит в том, чтобы генерировать случайные сообщения игроками для данных сезонов / раундов / игры.

Есть потребитель, который слушает все эти сообщения и будет отслеживать логику оценки.Как только оценка будет завершена, он опубликует счет в финальной теме.

Теперь вопрос, который меня смущает, заключается в том, как мой калькулятор очков узнает, что ВСЕ оценки игроков были получены до публикации окончательного результата?

1 Ответ

0 голосов
/ 13 июня 2018

Это удовольствие от неограниченных данных ... они не ограничены :-) То есть, на самом деле нет понятия "все данные" получены.

Вам необходимо встроить какую-то логику вВаше приложение, которое либо принимает решение по прошествии определенного периода времени, когда больше нет данных, оно завершает, либо приложение, которое отправляет данные, отправляет какое-то сообщение / водяной знак «конец подачи», чтобы указать, что прочитанное потребителем может бытьобработанный.

...