使用 Kafka 在 MassTransit 中发布与生产

Question

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

1. 就某个主题制作消息是否等同于发布活动？
2. 如何以正确的方式连接起来？欢迎提供一些简单的代码示例。

Answer 1

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

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

有单元测试显示它是如何工作的，我认为它还没有被记录下来。它是在 this commit

中添加的