在 .Net 中实现 Kafka 流处理器?

Implement Kafka Streams Processor in .Net?

这可能吗?

官方 .Net 客户端 confluent-kafka-dotnet 似乎只提供消费者和生产者功能。

并且(根据我记得很久以前对 Kafka 流的调查)我相信 Kafka Streams 处理器总是 运行 在 运行 Kafka 本身的 JVM 上。那样的话,基本上是不可能的。

是的,可以在 .NET 中 re-implement Apache Kafka 的 Streams 客户端库(Java 库)。但目前不存在这样的 ready-to-use Kafka Streams 实现。

And (from what I remember looking into Kafka streams quite a while back) I believe Kafka Streams processors always run on the JVMs that run Kafka itself. In that case, it would be principally impossible.

不,您所说的 Kafka Streams“处理器”不会 运行 在 Kafka 代理(的 JVM)中,即 server-side。

相反,Kafka Streams 客户端库用于实现 client-side Java/Scala/Clojure/... 流处理应用程序。这些应用程序通过网络与 Kafka 代理(构成 Kafka 集群)通信。

2020 年 5 月,似乎有一个项目正在开发中以支持 .NET 中的 Kafka Streams: https://github.com/LGouellec/kafka-stream-net

根据他们的路线图,他们现在处于早期测试阶段,并打算在今年年底或明年年初达到 v1