c# - .NET Web Core 5 API - 如何从我的 Linux 服务器使用 Kafka 消息？

Question

我制作了一个运行 Kafka 的 Linux 虚拟机。我测试了生产者并能够从我的另一台计算机上使用它。现在我想创建一个在我正在处理的 API 中运行的消费者。

我正在尝试遵循一些教程，但它们令人困惑。我只想运行一个消费者，它将在我的项目中读取来自生产者的消息。我下载了 Confluent.Kafka 包。然后我尝试制作一个 Services/ProcessOrdersService.cs 文件，如下所示：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.Extensions.Hosting;
using System.Threading;
using POS.Models;
using Newtonsoft.Json;
using Confluent.Kafka;

namespace POS.Services
{
    public class ProcessOrdersService
    {

        private readonly ConsumerConfig consumerConfig;

        public ProcessOrdersService(ConsumerConfig consumerConfig)
        {
            this.consumerConfig = consumerConfig;
        }
    }
}

但是我很困惑之后该怎么办？谁能指出我正确的方向？我试过看一些教程，但我不明白在我的 Web Core 5 API 项目中应该去哪里。

感谢您的任何帮助。:D

标签： c#asp.netasp.net-coreapache-kafkaproducer-consumer

Answer 1

您可能会发现我的文章很有帮助：我提供了有关如何使用 C# 的全面说明，并解释了一些微妙的点。

如果您有任何问题随时问！