Как выполнить отслеживание сообщений через стандартный открытый протокол телеметрии между kafka и веб-API в ядре .NET
Вариант использования
Я получаю сообщения от сторонней системы MF в свою очередь kafka. Каждое сообщение имеет свой уникальный идентификатор. Существует процессор сообщений .Net core kafka, который считывает сообщение из очереди и вызывает несколько веб-API.
Цель
Я хочу добиться непрерывной трассировки системных сообщений с использованием уникального идентификатора сообщения, полученного в очереди kafka. [Если это актуально] В моем стеке мы используем Serilog для обогащения журналов уникальным идентификатором сообщений и начали изучать инструментальную библиотеку OpenTelemetry.Net.
Вопрос
Как мне назначить уникальный идентификатор сообщения для System.Diagnostics.Activity.TraceID в процессоре Kafak .Net, чтобы любой вызов HttpClient, сделанный из этого exe к любому API, копировался через заголовки запроса.
В качестве альтернативы, пожалуйста, также дайте мне знать, если я подхожу к проблеме неправильно и уже существует стандартное решение для такого рода проблемы.