标签:生产 console sum 结构 keep 打开 replica consumer 进入
解压后进入conf目录,复制出一个zoo.cfg,然后进入bin目录,直接运行zkServer.cmd
首先你得有一个安装包:
解压,目录结构:
config目录里面是配置文件,在这里不做配置
在根目录,路径的位置输入cmd,回车即可跳出命令行
第一个坑
输入:
.\bin\windows\kafka-server-start.bat .\config\server.properties
经上网查阅得知,先设置CLSAAPATH,SO--
set classpath=.
出现一大堆,就成功了。
下面测试:先进入Windows目录搞出命令行,输入以下命令
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytest
第二个坑
还是老办法,先设置CLASSPATH。输入以下内容可以查看topic列表
kafka-topics.bat --list --zookeeper localhost:2181
下一步,创建生产者,输入:
kafka-console-producer.bat --broker-list localhost:9092 --topic mytest
下一步,打开一个新的命令行,输入以下内容
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mytest --from-beginning
现在,回到生产者的命令行,输入任意内容。你可以看见,当你回车之后,消费者自动收到你的消息
标签:生产 console sum 结构 keep 打开 replica consumer 进入
原文地址:https://www.cnblogs.com/LUA123/p/9264147.html