使用 Kafka 在 MassTransit 中发布与生产

【问题标题】：Publish vs Produce in MassTransit with Kafka使用 Kafka 在 MassTransit 中发布与生产
【发布时间】：2021-01-08 09:08:05
【问题描述】：

我想实现与 Kafka 主题集成的状态机。每当某个主题产生一些消息时，我希望状态机通过更改状态来做出反应。我有两个问题：

【问题讨论】：

【解决方案1】：

Produce 与 Publish 不同。您可以使用Produce 从状态机向 Kafka 中的主题发送消息：

Initially(
    When(Started)
        .Produce(x => x.Init<KafkaMessage>(new {Text = "text"}))
        .TransitionTo(Active));

有一些单元测试显示了它是如何工作的，我认为它还没有记录在案。已添加于this commit

【讨论】：