Пример использования заголовков с библиотекой Confluent Kafka C#

Question

Я пытаюсь использовать заголовки с Confluent Kafka C# API, но шаблон Message <> не имеет параметра Headers. Как передать заголовки методу ProduceAsyn c?

Answer 1

Я получил ответ от GitHub:

https://github.com/confluentinc/confluent-kafka-dotnet/issues/1193#issuecomment -591009614

, просто установите свойство Headers в объекте Message. Я не думаю, что есть пример проекта, который делает это, но здесь это делается в интеграционном тесте: https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/test/Confluent.Kafka.IntegrationTests/Tests/Headers.cs#L57