跨越Kafka和阿克卡河

mmvthczy  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(245)

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在本质上是相似的,所以一定有可能将这两种技术连接起来。我是阿克卡河的新成员,还不知道该怎么做。任何关于如何进行的想法或提示都是非常受欢迎的。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题