美文网首页
springboot与KafkaMQ的使用

springboot与KafkaMQ的使用

作者: LiKite | 来源:发表于2019-11-14 15:55 被阅读0次

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

相关文章

网友评论

      本文标题:springboot与KafkaMQ的使用

      本文链接:https://www.haomeiwen.com/subject/dgmrictx.html