В настоящее время я работаю с apache kafka и все еще учусь.Тем не менее, мы сталкиваемся с проблемой в производстве.
Сценарий: у нас есть две темы в kafka.
Первая Произведенная возможность MSG произведена и после Доходная позиция msg произведено.
- Возможность (данные возможности + данные позиции выручки в виде массива в той же платформе)
- Позиция Revenu (отдельная полезная нагрузка)
Когда мы получим возможность полезную нагрузку, мы перейдем к базе данных и найдем строки дохода , связанные с возможностью, и отправим ее конечному пользователю.Однако наши актеры-акки обрабатывают статьи доходов быстрее, чем возможности.Поэтому, когда мы отправляем позиции с доходами, они доходят до конечного пользователя, прежде чем появляется возможность.Когда мы видим данные в строке позиции дохода конечного пользователя, данные переопределяются со старой полезной нагрузкой.
Просьба указать, есть ли у kafka какой-либо подход к решению.