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

Есть ли какой-либо инструмент для отслеживания фактических сообщений, публикуемых через очередь NATS? Для презентации мне нужно отображать сообщения, отображаемые с помощью микросервисной архитектуры, и было бы неплохо сделать это с помощью...

У меня есть приложение узла, которое подключается к серверу NATS. Ниже мой docker-compose.yml для обоих серверов. version: "3" services: app: image: node:12.13.1 volumes: - ./:/app working_dir:...

Мы используем NATS и используем кластеризацию из 3+ узлов. У нас несколько производителей и много потребителей. Размеры сообщений небольшие (~ 100 байт), однако наша пропускная способность несколько высока. ~ 40к / сек. Весь трафик передается во...

Моя проблема в том, что мне нужно увеличить значение max_payload, которое получает NATS, но я понятия не имею, где это сделать. В проекте используется Moleculer, а NATS создается как контейнер с докером. Когда я пытаюсь сделать запрос размером...