У меня есть веб-сервер, который выполняет некоторую асинхронную обработку, отправляя данные потребителю kafka и возвращая ответ. Я хочу иметь возможность отслеживать веб-запрос + трассировку потребителя kafka за одну трассировку. Возможно ли это сделать?
Я попытался запустить потребителя kafka как дочерний элемент первого диапазона, но поскольку первый диапазон заканчивается, когда заканчивается запрос api, инструменты трассировки показывают неправильное время для трассировки. Я знаю, что делаю это неправильно. Может ли кто-нибудь указать мне направление для реализации такого требования.