Любая эталонная реализация для турбины Netflix с серверными событиями не Hystrix

Question

Я пытаюсь передать события на основе resilence4j (автоматический выключатель) на монитор потока турбины. у нас есть агрегатор турбинных потоков, который уже потребляет несколько потоков Hystrix из множества микросервисов. Все новые микросервисы пишутся на основе resilence4j, и мы хотели передать события на стороне сервера, которые resilence4j генерирует для передачи на турбину, чтобы мы могли совместно просмотреть все из них.

Согласно документации турбины https://github.com/Netflix/Turbine/wiki, любая пара значений ключа JSON может быть агрегирована при условии, что они генерируют события типа события на стороне сервера (SSE). Мне трудно это реализовать. Также исследован запах турбины в весеннем облаке.

Проблема, которую я вижу, заключается в том, что турбина выборочно ищет данные SSE на основе Hystrix. Любые предложения или мысли о том, как действовать, или это даже невозможно?

Answer 1

Не уверен, что в документации указаны правильные данные. Турбина ожидает тип, имя и групповую часть потока. как только мы добавим следующие пары KV в пару SSE. Ядро турбины заметил поток.

data: {"type":"circuitbreaker","name":"resilence4j","group":"wrench","current_time":"2019-11-02T15:04:54.241Z"... other values}