.net core 使用kafka

.NET Core可以使用第三方库来集成和使用Kafka。下面是一个简单的示例来演示如何在.NET Core中使用Kafka。

首先，你需要安装NuGet包`Confluent.Kafka`，这是一个Kafka客户端库。你可以通过NuGet包管理器或者使用命令行来安装它：

dotnet add package Confluent.Kafka

接下来，你可以使用以下代码来创建一个生产者并发送消息到Kafka：

using Confluent.Kafka;
using System;

class Program
{
    static void Main(string[] args)
    {
        var config = new ProducerConfig { BootstrapServers = "localhost:9092" };

        using (var producer = new ProducerBuilder<Null, string>(config).Build())
        {
            var topic = "my_topic";
            var message = "Hello Kafka!";

            var deliveryReport = producer.ProduceAsync(topic, new Message<Null, string> { Value = message }).GetAwaiter().GetResult();
            Console.WriteLine($"Message delivered to {deliveryReport.TopicPartitionOffset}");
        }
    }
}

上述代码创建了一个生产者实例，并将消息发送到名为"my_topic"的主题中。你可以根据自己的需求修改主题名称和消息内容。

如果你想要创建一个消费者并从Kafka接收消息，可以使用以下代码：

using Confluent.Kafka;
using System;

class Program
{
    static void Main(string[] args)
    {
        var config = new ConsumerConfig
        {
            BootstrapServers = "localhost:9092",
            GroupId = "my_group",
            AutoOffsetReset = AutoOffsetReset.Earliest
        };

        using (var consumer = new ConsumerBuilder<Ignore, string>(config).Build())
        {
            consumer.Subscribe("my_topic");

            while (true)
            {
                var consumeResult = consumer.Consume();
                Console.WriteLine($"Received message: {consumeResult.Message.Value}");
            }
        }
    }
}

上述代码创建了一个消费者实例，并订阅了"my_topic"主题。消费者将持续监听并接收来自Kafka的消息，并将其打印到控制台。

这只是一个简单的示例，你可以根据自己的需求来配置更多的Kafka生产者和消费者属性。希望能帮助到你！