卡夫卡怎么在春天引导中使用

　　介绍

这篇文章给大家介绍卡夫卡怎么在春天引导中使用,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。

<强>系统环境

使用远程服务器上搭建的卡夫卡服务

<李>

Ubuntu 16.04 LTS

<李>

kafka_2.12-0.11.0.0.tgz

<李>

zookeeper-3.5.2-alpha.tar.gz

<强>集成过程

1。创建春引导工程,添加相关依赖:

& lt; ? xml  version=?.0“,编码=癠TF-8" ?比; 　　& lt; project  xmlns=癶ttp://maven.apache.org/POM/4.0.0", xmlns: xsi=癶ttp://www.w3.org/2001/XMLSchema-instance" 　　,,,,xsi: schemaLocation=? http://maven.apache.org/POM/4.0.0 , http://maven.apache.org/xsd/maven-4.0.0.xsd"比; 　　& lt;才能modelVersion> 4.0.0</modelVersion> 　　 　　& lt;才能groupId> com.laravelshao.springboot</groupId> 　　& lt;才能artifactId> spring-boot-integration-kafka</artifactId> 　　& lt;才能version> 0.0.1-SNAPSHOT</version> 　　& lt;才能packaging> jar</packaging> 　　 　　& lt;才能name> spring-boot-integration-kafka</name> 　　& lt;才能description> Demo  project  for  Spring  Boot 　　 　　& lt;才能parent> 　　,,,& lt; groupId> org.springframework.boot 　　,,,& lt; artifactId> spring-boot-starter-parent 　　,,,& lt; version> 2.0.0.RELEASE 　　,,,& lt; relativePath/祝辞,& lt; !——, lookup  parent 得到repository ——比; 　　& lt;才能/parent> 　　 　　& lt;才能properties> 　　,,,& lt; project.build.sourceEncoding> UTF-8 　　,,,& lt; project.reporting.outputEncoding> UTF-8 　　,,,& lt; java.version> 1.8 & lt;/java.version> 　　& lt;才能/properties> 　　 　　& lt;才能dependencies> 　　,,,& lt; dependency> 　　,,,,,& lt; groupId> org.springframework.boot 　　,,,,,& lt; artifactId> spring-boot-starter 　　,,,& lt;/dependency> 　　,,,& lt; !——卡夫卡——比; 　　,,,& lt; dependency> 　　,,,,,& lt; groupId> org.springframework.kafka 　　,,,,,& lt; artifactId> spring-kafka 　　,,,& lt;/dependency> 　　,,,& lt; dependency> 　　,,,,,& lt; groupId> org.springframework.boot 　　,,,,,& lt; artifactId> spring-boot-starter-json 　　,,,& lt;/dependency> 　　,,,& lt; dependency> 　　,,,,,& lt; groupId> org.springframework.boot 　　,,,,,& lt; artifactId> spring-boot-starter-test 　　,,,,,& lt; scope> test 　　,,,& lt;/dependency> 　　& lt;才能/dependencies> 　　 　　& lt;才能build> 　　,,,& lt; plugins> 　　,,,,,& lt; plugin> 　　,,,,,,,& lt; groupId> org.springframework.boot 　　,,,,,,,& lt; artifactId> spring-boot-maven-plugin 　　,,,,,& lt;/plugin> 　　,,,& lt;/plugins> 　　& lt;才能/build> 　　& lt;/project>

2。添加配置信息,这里使用yml文件

春: 　　,卡夫卡: 　　bootstrap-servers才能:X.X.X.X: 9092 　　制作人:才能 　　,,value-serializer: org.springframework.kafka.support.serializer.JsonSerializer 　　消费者才能: 　　,才能组id:测试 　　,,auto-offset-reset:最早 　　,,value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer 　　,,属性: 　　春天,,,: 　　,,,,json: 　　,,,,,信任: 　　,,,,,,包:,com.laravelshao.springboot.kafka

3。创建消息对象

public  class  Message  { 　　private 才能Integer  id; 　　private 才能String 味精; 　　 　　public 才能;消息(),{ 　　,,} 　　 　　public 才能;信息(id、Integer  String 味精),{ 　　,,,this.id =, id; 　　,,,this.msg =,味精; 　　,,} 　　 　　public 才能;Integer  getId (), { 　　,,,return  id; 　　,,} 　　 　　public 才能;void  setId (Integer  id), { 　　,,,this.id =, id; 　　,,} 　　 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null

卡夫卡怎么在春天引导中使用