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

Eug*_*sky 5 apache-kafka apache-kafka-streams

那可能吗?

正式的.Net客户端融合的kafka-dotnet似乎仅提供消费者和生产者功能。

而且(从我记得很久以前就研究过Kafka流的情况来看),我相信Kafka Streams处理器始终在运行Kafka本身的JVM上运行。在这种情况下,原则上是不可能的。

Tom*_*gan 10

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

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


Mic*_*oll 6

是的,可以在.NET中重新实现Apache Kafka的Streams库(一个Java库)。但是目前尚不存在用于.NET的此类即用型Kafka Streams实现。

而且(从我记得很久以前就研究过Kafka流的情况来看),我相信Kafka Streams处理器始终在运行Kafka本身的JVM上运行。在这种情况下,原则上是不可能的。

不,您所说的Kafka Streams“处理器”不在Kafka代理=服务器端(的JVM)中运行。Kafka Streams库用于实现客户端Java / Scala / Clojure / ...应用程序以进行流处理。这些应用程序通过网络与Kafka代理(构成Kafka集群)对话。

  • 谢谢。仅供参考,我称处理器为 Kafka 所称:[_Processors_](https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/Processor.爪哇)。 (2认同)
  • 这是为此的github问题:https://github.com/confluentinc/confluent-kafka-dotnet/issues/344 (2认同)