SendMeAnAngel
Czy ktoś ogarnia Kafkę w Quarkusie? Mam takie zagadnienie:

- serwis A wysyła komunikat "wykonaj_polecenie" na kolejkę "polecenia"
- serwis B pobiera ten komunikat i wywołuje zewnętrzną usługę, ale leci timeout
- połączenie z Kafką jest zrywane i cały serwis B wisi

Co
1
  • Najlepsze
  • Wszystkie komentarze
Myzreal
@SendMeAnAngel: Skróć timeout wywołania zewnętrznej usługi albo wydłuż okienko procesowania eventu z kafki żeby zdążyć ten timeout złapać zanim kafka uzna cię za zawieszoną aplikację i w przypadku timeout albo daj znać kafce że nie przeprocesowałeś eventu - dostaniesz go jeszcze raz i przeprocesujesz ponownie - albo wrzuć go na jakieś DLQ i leć z następnym
0
SendMeAnAngel
@Myzreal: To chyba wszystko jedno, czy ręcznie zwrócę NACK, czy poleci Exception, jeśli pozostawię obecny tryb failure - połączenie z Kafką zostanie zerwane i nie wiadomo, co dalej z tym zrobić i czy mogę to jakoś przechwycić.

Czyli wychodzi na to, że zmniejszyć timeout dla usługi i jeśli poleci timeout, to wtedy podjąć jakąś akcję, np. zrestartować usługę lub całą aplikację.

DLQ to też może być dobry pomysł - nie
0