一、说明
????????1、作业开发环境一般是Windows
????????2、看其他同志的文章,不是很简洁,整起
二、操作步骤
1、下载Kafka
1)kafka_2.13-2.8.0.tgz
2)若失效,请到官网自行下载
?2、解压并配置环境变量
1)解压目录

2)增加环境变量
E:\hgSuper\java\kafka_2.13-2.8.0\bin\windows

?3、启动zk
1)kafka启动依赖zookeeper,所以需要先启动zk
2)直接参考脚本,zk.bat
e:
cd E:\hgSuper\java\kafka_2.13-2.8.0\config
zookeeper-server-start.bat zookeeper.properties
?4、启动kafka
1)直接参考脚本,kafka.bat
e:
cd E:\hgSuper\java\kafka_2.13-2.8.0\config
kafka-server-start.bat server.properties
?5、其他命令
1)查看topic列表
e:
cd E:\hgSuper\java\kafka_2.13-2.8.0\config
kafka-topics.bat --list --zookeeper localhost:2181
2)创建topic
e:
cd E:\hgSuper\java\kafka_2.13-2.8.0\config
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic iris
3)创建生产者
e:
cd E:\hgSuper\java\kafka_2.13-2.8.0\config
kafka-console-producer.bat --broker-list localhost:9092 --topic iris
4)创建消费者
e:
cd E:\hgSuper\java\kafka_2.13-2.8.0\config
kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic iris --from-beginning
?三、Swing演示
1、生产者

?2、消费者

?3、有需要请联系
????????1、源码,
????????2、有需要,请关注微信公众号: hgSuper
????????3、留言即可,留言内容请填写: Kafka演示
?
|