springboot對kafka的client很好的實(shí)現(xiàn)了集成,使用非常方便,本文也實(shí)現(xiàn)了一個在springboot中實(shí)現(xiàn)操作kafka的demo。
創(chuàng)新互聯(lián)是一家專注網(wǎng)站建設(shè)、網(wǎng)絡(luò)營銷策劃、微信小程序開發(fā)、電子商務(wù)建設(shè)、網(wǎng)絡(luò)推廣、移動互聯(lián)開發(fā)、研究、服務(wù)為一體的技術(shù)型公司。公司成立十年以來,已經(jīng)為成百上千成都不銹鋼雕塑各業(yè)的企業(yè)公司提供互聯(lián)網(wǎng)服務(wù)?,F(xiàn)在,服務(wù)的成百上千客戶與我們一路同行,見證我們的成長;未來,我們一起分享成功的喜悅。1.POM配置
只需要在dependencies中增加 spring-kafka的配置即可。完整效果如下:
org.springframework.boot spring-boot-starter-parent 1.5.4.RELEASE 1.8 1.2.2.RELEASE UTF-8 org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-test test org.springframework.boot spring-boot-starter-aop org.springframework.kafka spring-kafka ${spring-kafka.version} org.springframework.kafka spring-kafka-test ${spring-kafka.version} test