Názor k článku Nástroj MirrorMaker pro Apache Kafku od Ján Halaša - Ďakujem za prínosný článok aj diskusiu. Zrovna sa...

Ďakujem za prínosný článok aj diskusiu. Zrovna sa snažím vymyslieť fungovanie aplikácie s Kafkou replikovanou na dvoch prostrediach pre disaster recovery / high availability cez MirrorMaker2. Aktívne bude vždy len jedno prostredie. Po prepnutí prostredia by sa nemali stratiť nespracované správy z prvého (a rovnako pri prepnutí späť). Takže každé prostredie bude mať základné topiky a ich mirrorované verzie, na ktorých bude chcieť spracovať len správy nespracované v ich pôvodnom prostredí. Databáza aplikácie sa replikuje tiež.

Má prosím niekto skúsenosti s takýmto prostredím? Asi hlavne ako sa vyhnút duplicitnému spracovaniu správ (na oboch prostrediach) a zároveň spracovať správy, ktoré sa "nestihli spracovať" na tom druhom. Používať na to nejaké ID správ, alebo nejaký semafor určujúci, ktoré prostredie spracováva správy?