[karetpoker]

@mirunek do kafki możesz ładować

[karetpoker]

@mirunek kafka to taki rabbitmq, tylko że kafka ma w dupie, co z message się dzieje, pakuje go na topic i elo, consumerzy sami się odhaczają, co zdążyli przeczytać

i ustawisz, żeby w----------o to z kafki po tygodniu czy po iluś megabajtach (ile ci potrzebne) i elo

[a.....e]

@karetpoker rabbit to taka powolna wersja kafki dla biedakow

[mirunek]

@JanPawelDrugiLechWalesaPierwszy dzięki za "słowa klucze". Będę drążył.

@karetpoker @karetpoker dzięki. Co do kafki, jeśli Core API zaktualizował produkt, po 2 sekunfach znowu, wysłał 2 wiadomości to bez problemu mogę jakoś oznaczyć "czas" utworzenia, tak aby te wiadomości były konsumowane w odpowiedniej kolejności?

[karetpoker]

@mirunek a to ty już się tym musisz zająć

[nad__czlowiek]

@mirunek: sns/sqs

[fujiyama]

@mirunek: możesz to zrobić też bez eventów jeśli to jedyne wymaganie co do komunikacji.
Zrób usługę w CoreAPI, która odpowie na pytanie jakie produkty się zmieniły od określonego momentu.
Każdy serwis będzie mógł o to zapytać.
Jest to mnie efektywne bo każdy zapyta osobno, ale proste do napisania i nie wymaga instalacji kolejnego elementu, subskrybcji itp.

[karetpoker]

@fujiyama bez sensu, generuje zbędne zapytania, gdy się nic nie zmieniło

[karetpoker]

@mirunek w sumie przemyślałem sprawę i tego rabbita też możesz użyć

będziesz publikował message nie do kolejki, tylko na exchange z routing tagiem i stamtąd ta wiadomość się skopiuje na wiele kolejek

jeden konsument = jedna kolejka

w to bym poszedł, kafka się lepiej sprawdza, jeśli potrzebujesz jakiegoś persistency i chcesz dużo rzeczy obsługiwać out of order

[Gotomb]

@karetpoker po co w---------ć coś z kafki?