一直在尝试检查是否有人能够在实时流应用程序上使用 Dagster 编排。我已经能够使用批处理位来实现，但没有获得任何实时文档。
尝试实现 Kafka。
结帐https://github.com/conductor-oss/conductor。任务执行之间间隔 10 毫秒，非常适合近/实时用例