到官网下载后缀名为.tgz的文件,kafka_2.13-2.5.0.tgz,tgz是压缩文件,Windows需解压两次。
启动kafka前需要先启动Zookeeper,CMD到kafka文件路径下
• cd {KAFAK_HOME}
# start zookeeper service (port: 2181)
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
再开另一个CMD窗口
• cd {KAFAK_HOME}
# start kafka broker serivce (port: 9092)
bin\windows\kafka-server-start.bat config\server.properties
再开另一个CMD窗口,创建一个只有1个partition(分区)和1个replication-factor(备份),叫做test的topic
• cd {KAFAK_HOME}
# create a new kafka topic "test"
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
创建好之后,可以通过运行以下命令,查看已创建的topic信息:
# list out all kafka topic
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
还可以用describe 命令查看更详细的topic信息
# describe specific kafka topic "test"
bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic test
使用控制台producer 将数据发布到主题
# publish data to specific kafka topic "test"
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
>Hello
>Hello2
原文:https://www.cnblogs.com/fangjb/p/12912002.html