MassTransit Kafka在运行时添加生产者

Question

有没有办法从控制器中动态添加生产者?我们在运行时获得主题名称，需要使用rider.AddProducer<ClassA,ClassB>()添加主题名称，然后使用GetRequiredService<ClassA,ClassB>>()检索其实例。我已经看了文档和这个问题，但是没有找到答案。Kafka Producer with MassTransit - IBusInstance未注册

Answer 1

目前还没有办法动态添加Kafka主题生产者——它们必须在rider配置时声明。

这似乎是一个合理的功能请求，你可以在这里提交一个。

Answer 2

在审查了你的问题并将其与我的问题联系起来之后，我在MassTransit Kafka集成上创建了一个包装器来动态处理它的生产者。你可以在这个地址看到它:

github库