我正在开发一个容器化应用程序，其中一个前端应用程序向api网关调用http请求。api网关接收到的请求数据通过kafka转发给微服务。但是我必须将响应作为响应发送回api网关和前端应用程序。有谁能指导我如何通过kafka实现api网关和micron服务之间的同步请求和响应。
我试过与生产商和消费者，这就像火和忘记我在哪里无法回应的要求。
提前谢谢。
阿伦

using Confluent.Kafka;

Producer Code
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);

Consumer Code

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);