Как добавить свойства заголовка в сообщение kafka при отправке сообщения производителю, используя C#? - PullRequest
Новая
       53

Как добавить свойства заголовка в сообщение kafka при отправке сообщения производителю, используя C#?

1 голос
/ 13 апреля 2020 
                var router = new BrokerRouter(options);
                var client = new KafkaNet.Producer(router, maximumAsyncRequests, maximumMessageBuffer);
                var text="";
                    var fileStream = new FileStream(@"D:/kafka_examples/consumed_files123.ifc", FileMode.Open, FileAccess.Read);
                    using (var streamReader = new StreamReader(fileStream, Encoding.UTF8))
                    {
                        text = streamReader.ReadToEnd();
                     Console.WriteLine(text);
                    client.SendMessageAsync("Hello-Kafka", new[]
                  { new Message(text) }).Wait();

                }

Это код, который я использовал для отправки своего сообщения производителю, который работает нормально, но теперь я хочу добавить некоторые свойства заголовка к сообщению. Пожалуйста, помогите мне сейчас добавить свойства заголовка, используя C#.

...