springboot与KafkaMQ的使用
2019-11-14 本文已影响0人
LiKite
1、 KafkaMQ 消息队列简介
Kafka MQ是一个高吞吐量分布式消息系统。是由linkedin开源的消息中间件。 Kafka就跟这个名字一样,设计非常独特
百度:https://baike.baidu.com/item/KafkaMQ/8858129?fr=aladdin
2、springboot中配置
(1)pom文件:

(2)application.properties配置

(3)代码



Java 完结!!!
3、windows下配置 KafkaMQ 服务!
(1)下载 KafkaMQ
下载地址:https://www.apache.org/dyn/closer.cgi?path=/kafka/2.3.1/kafka_2.12-2.3.1.tgz (选择二进制文件)
(2)文件解压,放置相应的路径

(3)确保电脑上已装 Java 环境!
要知道 zookeeper的默认端口是2181,生产者的默认端口是9092!!!
启动zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
启动kafka
bin\windows\kafka-server-start.bat config\server.properties
创建主题topic,topic = mytop
bin\windows\kafka-topics.bat--create--bootstrap-serverlocalhost:9092--replication-factor1--partitions1--topictest
bin\windows\kafka-topics.bat--list--bootstrap-serverlocalhost:9092