在 .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
这可能吗?
官方 .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