kafka流仅在jvm平台上受支持。因此,我正在寻找一种方法,利用阿克卡流在c#建立一个Kafka消费者的利益,从阿克卡流。
融合的c#kafka消费者基于轮询和事件处理,例如。
using (var consumer = new Consumer<Null, string>(consumerConfig, null, new StringDeserializer(Encoding.UTF8)))
{
// Subscribe to the OnMessage event
consumer.OnMessage += (obj, msg) =>
{
// handle message
};
consumer.Subscribe(new List<string>() { kafkaTopic });
while (!cancelled)
{
consumer.Poll();
}
}
akka溪流的来源似乎是基于ienumerable。由于polling和ienumerable在本质上是相似的,所以一定有可能将这两种技术连接起来。我是阿克卡河的新成员,还不知道该怎么做。任何关于如何进行的想法或提示都是非常受欢迎的。
暂无答案!
目前还没有任何答案,快来回答吧!