Как работать с exception в микросервисах NestJS с Kafka?
Нужен рабочий пример как работать с исключениями, ошибками в микросервисах NestJS с брокером Kafka.
В документации написано, что просто замените HttpException на RpcException и всё будет работать.
Пробовал - не работает, на клиенте зависает ожидание ответа сервера.
В гугле пишут, что необходимо использовать кастомный фильтр исключений. Перепробовал несколько предлагаемых вариантов, делал сам по докам. Так же не работает.
Замечу, что клиент с сервером работают, сообщениями обмениваются, но исключения на клиента с сервера не приходят.
Простой
