。

但是就目前流行的开发语言#xff0c;尤其是面向web方向应用的#xff0c;我感觉就是Nodejs最简单了。

下面介绍#xff1a;

本文将会介绍在windows环境下启动Kafka#xff0c;并通过n…本人是C#出身的程序员c#很简单就能实现有需要的可以加我私聊。

但是就目前流行的开发语言尤其是面向web方向应用的我感觉就是Nodejs最简单了。

下面介绍

本文将会介绍在windows环境下启动Kafka并通过nodejs作为客户端生产并消费消息。

步骤一Kafka需要java运行时先安装配置java环境。

通过在命令行中输入java

-version确认java是否成功安装(可能需要查看windows的环境变量中是否有java)。

步骤二Kafka官网下载最新版本的压缩包(.tgz格式)并解压。

分别在两个命令行里面启动zookeeper、kafka解压缩路径下

bin\windows\zookeeper-server-start.bat

bin\windows\kafka-server-start.bat

说明一下zookeeper和kafka的关系:zookeeper是集群的调度者kafka才是消息队列。

zookeeper的默认端口2181kafka的默认端口9092

相关配置可以在config文件下的server.properties和zookeeper.properties中找到

建立data,logs,kafka-logs目录用于日志备用。

消费者客户端需要的group.id可以在config-consumer.properties中找到。

步骤三使用DOS的CMD管理员命令行方式测试生产者生产、消费者消费。

//创建一个topictest

bin\windows\kafka-console-producer.bat

--broker-list

bin\windows\kafka-console-consumer.bat

--bootstrap-server