Как работать с exception в микросервисах NestJS с Kafka?

Question

[Lexx Xell]

Нужен рабочий пример как работать с исключениями, ошибками в микросервисах NestJS с брокером Kafka.

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

Замечу, что клиент с сервером работают, сообщениями обмениваются, но исключения на клиента с сервера не приходят.