使用Kafka + . net Core + MassTransit实现请求响应模式

Question

谁能告诉我如何使用。net core(2.1,2)实现kafka的请求响应模式?或3.1)。我更喜欢使用轻量级消息总线MassTransit来实现这个模式。我无法在他们的文档中找到参考实现。也许我错过了。谁能分享一些使用MassTransit的标准参考实现。如果找不到，任何使用Confluent Kafka实现的示例(请求响应模式的实现)也很值得一看。

谢谢所有的

Answer 1

Kafka不是为RPC设计的，所以不建议在Kafka上做请求/响应。这也是为什么MassTransit不支持使用Kafka主题的请求/响应。