arunrv Ответов: 0

Реализация HTTP синхронного запроса ответа в Кафке

Всем Привет,

Я работаю над приложением контейнеризации, где интерфейсное приложение вызывает HTTP-запрос к шлюзу API. Запрос на данные, полученные в шлюз API является вперед к микро сервис через Кафку. Но я должен отправить ответ обратно результат как ответ обратно в API gateway и обратно в front-end приложение.
Может ли кто-нибудь, пожалуйста, указать мне, как я могу добиться синхронного запроса и ответа между API gateway и службой micron через Kafka.

Я пробовал работать с производителем и потребителем, что подобно огню и забвению, когда я не могу ответить на запрос.

заранее спасибо.

Арун

Что я уже пробовал:

Код Производителя

using var p = new ProducerBuilder<string, string>(config).Build();
 // Send the message to our test topic in Kafka                
                var dr = await p.ProduceAsync("test", message);



Потребительский Код

using var c = new ConsumerBuilder<Ignore, string>(conf).Build();
  c.Subscribe("test");
 // Consume a message from the test topic. 
                    var cr = c.Consume(cts.Token);

0 Ответов