一、安装
1.需要jdk
2.需要zookeeper,这个东西在最新版的Kafka中内置。
3.下载Kafka安装包
下载地址:http://kafka.apache.org/downloads
注意:src结尾的时未编译项目(一般不下这个),下已编译项目Binary downloads这个
下载最新版本。随便找一个舒服的目录解压。
我解压到本电脑的D:DocumentsDownloads目录。
二、运行zookeeper
cd到解压的Kafka的文件位置。
启动zookeeper(这个zookeeper是kafka内置的,新版本都是内置的,旧版本需下载一个zookepper)
binwindowszookeeper-server-start.bat configzookeeper.properties
运行结果:不报error就是成功了
三、运行kafka
cd到解压的Kafka的文件位置。我的是D:DocumentsDownloadskafka_2.12-2.2.0 执行下面的命令
binwindowskafka-server-start.bat configserver.properties
运行结果:
四、简单使用
创建主题topic,topic = demo
binwindowskafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic demo
-- 查看创建的topic
binwindowskafka-topics.bat --list --bootstrap-server localhost:9092
启动生产者 producer
binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic demo
启动生产者之后进入编辑页面,发送了 "nihao",
启动消费者 customer
binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning
当消费者启动之后,收到了之前生产者发送的 “nihao”。
注意:消费端数据中文乱码问题
解决:CHCP 65001
原因:kafka默认编码是utf-8,但win10是gbk,所以中文乱码,仅需在cmd下设置本机局部编码格式位utf-8即可解决(CHCP 65001)