框架: spring-kafka 1.2.2
生產(chǎn)者端代碼
說明:
bootstrapServers: kafka 地址
kafkaTemplate: 服務(wù)調(diào)用模板
消費(fèi)端代碼:
說明:
@EnableKafka : 開啟kafka
bootstrapServers: kafka 地址
groupIdConfig: 群組名稱
consumerConfigs(): 客戶端配置
consumerFactory():客戶端工廠
kafkaListenerContainerFactory(): 配置kafka監(jiān)聽工廠
實(shí)際使用:
發(fā)送消息:
指定話題和內(nèi)容,框架會(huì)發(fā)送到對(duì)應(yīng)的話題
接收消息:
使用
@KafkaListener 注解并加上對(duì)應(yīng)的話題,就可以自動(dòng)接收相應(yīng)的消息