如何解决使用 Kafka 在 MassTransit 中发布与生产
我想实现与 Kafka 主题集成的状态机。每当某个主题产生一些消息时,我希望状态机通过更改状态来做出反应。我有两个问题:
- 针对某个主题生成消息是否与发布事件相同?
- 如何以正确的方式连接东西?欢迎提供一些简单的代码示例。
解决方法
Produce
与 Publish
不同。您可以使用 Produce
从状态机向 Kafka 中的主题发送消息:
Initially(
When(Started)
.Produce(x => x.Init<KafkaMessage>(new {Text = "text"}))
.TransitionTo(Active));
有一些单元测试显示了它是如何工作的,我认为它尚未被记录在案。它是在 this commit
中添加的版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。