在一次項目中,因甲方需要使用kafka消息隊列推送數據,所以需要接入kafka,並且kafka的版本是2.11。但是我們項目使用的是Springboot 1.5.7的版本,對應的springboot.kafka.starter有沖突,所以就接入了kafka-client。
springboot接入kafka-client還是比較簡單的,這里只是做一個記錄。
pom文件中添加如下依賴即可
<!-- kafka集成 開始--> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.0.1</version> </dependency> <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> <version>1.1.8.RELEASE</version> <exclusions> <exclusion> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> </exclusion> </exclusions> </dependency> <!-- kafka集成 結束-->