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博客