169 похожих чатов

Ребят есть кто тут силен с кафкой ? Не получается исправить

- у меня проблемка в том что запрос к микроссервису (чтобы узнать количество просмотров) происходит раньше, чем обработка сообщения из Kafka и инкрементация счетчика. И таким образом идет отставание на 1. Тоесть в базе (микроссервиса) к примеру 5 просмотров, а в rest запросе показывает 4.

7 ответов

15 просмотров

а можно кейс по-подробнее? кто являеся источником сообщения в кафке, а кто дергает по рест

O-Z Автор вопроса

вот и вся логика в общем то

O Z
screenshot вот и вся логика в общем то

а что ты ожидал то от этого кода?) с вероятностью наверно 90% содержимое runAsync не начнет выполняться пока ты не выйдешь из метода, где ты его вызвал) т.е. рест запрос будет 100% сделан раньше, даже чем сообщение будет записано в кафку, не то что прочитано и обработано

O-Z Автор вопроса
Alexandr ∨∧‾ Emelyanov
а что ты ожидал то от этого кода?) с вероятностью ...

Спасибо! Критика весьма полезна и мною очень одобряема ! Но только в том случае когда дают лучшее решение 👍 Тут дело в том что если убрать аrunAsync, это гарантирует что сообщение будет отправлено на Kafka до того, как метод продолжит выполнение. Но это также означает что метод будет ждать завершения этого вызова, и это может увеличить задержку для пользователя... 😕 ХЗ как это лучше закодить, много вариантов, что лучше не понять пока что

O Z
Спасибо! Критика весьма полезна и мною очень одобр...

эта логика в принципе вся кривая. почему это все не в одном сервисе делать?

O-Z Автор вопроса
Alexandr ∨∧‾ Emelyanov
эта логика в принципе вся кривая. почему это все н...

делал в одном, потом специально разбил.... это не суть

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта