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

Всем привет коллеги, подскажите пожалуйста как реализовать такое с кафкой? 1)

запрашивается удаленно свободный рабочий сервер по rest и в ответе получаем ip и port (это уже сделали)

2) как только получили сервер, подключаемся к кафке и запрашиваем сообщение - вот тут застряли, так как кафка не заточена чтобы ее одиночно дергать, она заточена чтобы листнер постоянно слушал топик. Но нам нелья получать сообщение раньше чем получим доступный сервер на котором сможем исполнить это сообщение (задание).

Не знаем как решить такое..

7 ответов

22 просмотра

а точно кафка нужна? судя по описанию - нет

Denis Pavlyuchenko
а точно кафка нужна? судя по описанию - нет

Бахнули распределённый семафор/лок и поехали...

а что мешает дергать конкретный топик/партицию по конкретному оффсету?

As@@t-A Автор вопроса
Denis Pavlyuchenko
а точно кафка нужна? судя по описанию - нет

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

As@@t-A Автор вопроса
Aleksandr Gavrilov
а что мешает дергать конкретный топик/партицию по ...

трудно контролить оффсет, так как в группе много консюмеров

As@@t A
трудно контролить оффсет, так как в группе много к...

тогда как мне кажется надо думать другую архитектуру

As@@t-A Автор вопроса
Aleksandr Gavrilov
тогда как мне кажется надо думать другую архитекту...

пожалуй да, будем рандомно брать строку с монго со статусом 0 (ожидает обработки), локать в хэзелкаст, писать новый статус 1 (в работе) и забирать.. видимо и в правду от кафки тут одни страдания

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

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

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
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
Карта сайта