1.安装jdk8

参考教程java8安装教程_java8u371安装教程-CSDN博客

下载kafak安装包：

kafka_2.12-3.6.1.tgz

解压：

启动ZooKeeper软件，kafka内部已近集成了该软件。

• 进入Kafka解压缩文件夹的config目录，修改zookeeper.properties配置文件

提前创建好数据目录：

修改为：

E:/Code/kafka/data/zk

启动，进入目录下：

E:\Code\kafka\bin\windows

创建快捷运行脚本：

call bin/windows/zookeeper-server-start.bat config/zookeeper.properties

可以看到kafka运行后，能够生成对应的文件夹及文件。

启动Kafka：
进入Kafka解压缩文件夹的config目录，修改server.properties配置文件。

修改为如下：

E:/Code/kafka/data/kafka

其他配置保持默认即可。

启动：前提是需要先运行zk。

关闭顺序为：先关闭kafka，后关闭zk，到此测试环境就已经搭建好了。

同理，创建启动kafka的快捷脚本。

call bin/windows/kafka-server-start.bat config/server.properties

生成的文件：

C#测试发布订阅：

创建控制台项目，安装依赖;

步骤 2: 创建 Kafka 生产者

using Confluent.Kafka;
using System;
using System.Threading;
 
class Program
{
    static void Main()
    {
        var config = new ProducerConfig
        {
            BootstrapServers = "your_kafka_bootstrap_servers"
        };
 
        using (var producer = new ProducerBuilder<Null, string>(config).Build())
        {
            string topic = "your_kafka_topic";
 
            for (int i = 0; i < 10; i++)
            {
                string message = $"Message {i}";
                var deliveryReport = producer.ProduceAsync(topic, new Message<Null, string> { Value = message }).Result;
                Console.WriteLine($"Delivered '{deliveryReport.Value}' to '{deliveryReport.TopicPartitionOffset}'");
            }
        }
    }
}

参考教程如下：

C#整合kafuka_c# kafka-CSDN博客