这里会显示出您选择的修订版和当前版本之间的差别。
两侧同时换到之前的修订记录 前一修订版 | |||
分享:技术:jms:spring整合kafka [2018/05/11 10:27] gxx |
分享:技术:jms:spring整合kafka [2018/05/11 13:33] (当前版本) gxx |
||
---|---|---|---|
行 538: | 行 538: | ||
2018-05-11 10:20:26,662 [messageListenerContainer_trade-kafka-listener-1] INFO [com.gxx.record.web.kafka.KafkaConsumer:36] - ~~~~~~~~~~~~~kafkaConsumer消费结束~~~~~~~~~~~~~ | 2018-05-11 10:20:26,662 [messageListenerContainer_trade-kafka-listener-1] INFO [com.gxx.record.web.kafka.KafkaConsumer:36] - ~~~~~~~~~~~~~kafkaConsumer消费结束~~~~~~~~~~~~~ | ||
</code> | </code> | ||
+ | ===== spring官方版本对应 ===== | ||
+ | [[https://projects.spring.io/spring-kafka/|spring官方版本对应]] | ||
+ | ^ Spring for Apache Kafka Version ^ Spring Integration for Apache Kafka Version ^ kafka-clients Version ^ | ||
+ | | 2.2.x | 3.1.x | 1.1.x | | ||
+ | | 2.1.x | 3.0.x | 1.0.x, 1.1.x | | ||
+ | | 2.0.x | 3.0.x | 0.11.0.x, 1.0.x | | ||
+ | | 1.3.x | 2.3.x | 0.11.0.x, 1.0.x | | ||
+ | | 1.2.x | 2.2.x | 0.10.2.x | | ||
+ | | 1.1.x | 2.1.x | 0.10.0.x, 0.10.1.x | | ||
+ | | 1.0.x | 2.0.x | 0.9.x.x | | ||
+ | | N/A* | 1.3.x | 0.8.2.2 | | ||
+ | ===== springboot整合kafka ===== | ||
+ | spring配置和逻辑代码基本一致,主要是pom.xml的配置,这里记录如下(多余的一些配置,比如工作流camunda,请忽略): | ||
+ | <code xml pom.xml> | ||
+ | <?xml version="1.0" encoding="UTF-8"?> | ||
+ | <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://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"> | ||
+ | <modelVersion>4.0.0</modelVersion> | ||
+ | |||
+ | <groupId>com.example</groupId> | ||
+ | <artifactId>demo</artifactId> | ||
+ | <version>0.0.1-SNAPSHOT</version> | ||
+ | <packaging>jar</packaging> | ||
+ | |||
+ | <name>ui</name> | ||
+ | <description>Demo project for Spring Boot</description> | ||
+ | |||
+ | <parent> | ||
+ | <groupId>org.springframework.boot</groupId> | ||
+ | <artifactId>spring-boot-starter-parent</artifactId> | ||
+ | <version>2.0.1.RELEASE</version> | ||
+ | <relativePath /> <!-- lookup parent from repository --> | ||
+ | </parent> | ||
+ | |||
+ | <properties> | ||
+ | <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> | ||
+ | <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> | ||
+ | <java.version>1.8</java.version> | ||
+ | <camunda.version>7.8.0</camunda.version> | ||
+ | </properties> | ||
+ | |||
+ | <dependencyManagement> | ||
+ | <dependencies> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.boot</groupId> | ||
+ | <artifactId>spring-boot-dependencies</artifactId> | ||
+ | <version>2.0.1.RELEASE</version> | ||
+ | <type>pom</type> | ||
+ | <scope>import</scope> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.camunda.bpm</groupId> | ||
+ | <artifactId>camunda-bom</artifactId> | ||
+ | <version>${camunda.version}</version> | ||
+ | <scope>import</scope> | ||
+ | <type>pom</type> | ||
+ | </dependency> | ||
+ | </dependencies> | ||
+ | |||
+ | </dependencyManagement> | ||
+ | |||
+ | <dependencies> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.boot</groupId> | ||
+ | <artifactId>spring-boot-starter-security</artifactId> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.boot</groupId> | ||
+ | <artifactId>spring-boot-starter-web</artifactId> | ||
+ | </dependency> | ||
+ | |||
+ | <dependency> | ||
+ | <groupId>org.springframework.boot</groupId> | ||
+ | <artifactId>spring-boot-starter-test</artifactId> | ||
+ | <scope>test</scope> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.security</groupId> | ||
+ | <artifactId>spring-security-test</artifactId> | ||
+ | <scope>test</scope> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.ldap</groupId> | ||
+ | <artifactId>spring-ldap-core</artifactId> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.security</groupId> | ||
+ | <artifactId>spring-security-ldap</artifactId> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>com.unboundid</groupId> | ||
+ | <artifactId>unboundid-ldapsdk</artifactId> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.camunda.bpm.springboot</groupId> | ||
+ | <artifactId>camunda-bpm-spring-boot-starter</artifactId> | ||
+ | <version>2.3.0</version> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.camunda.bpm.springboot</groupId> | ||
+ | <artifactId>camunda-bpm-spring-boot-starter-rest</artifactId> | ||
+ | <version>2.3.0</version> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.camunda.bpm.springboot</groupId> | ||
+ | <artifactId>camunda-bpm-spring-boot-starter-webapp</artifactId> | ||
+ | <version>2.3.0</version> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>com.h2database</groupId> | ||
+ | <artifactId>h2</artifactId> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>ch.qos.logback</groupId> | ||
+ | <artifactId>logback-classic</artifactId> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.camunda.bpm.identity</groupId> | ||
+ | <artifactId>camunda-identity-ldap</artifactId> | ||
+ | </dependency> | ||
+ | |||
+ | <!-- kafka --> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.kafka</groupId> | ||
+ | <artifactId>spring-kafka</artifactId> | ||
+ | <version>2.1.5.RELEASE</version> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.springframework.integration</groupId> | ||
+ | <artifactId>spring-integration-kafka</artifactId> | ||
+ | <version>1.3.0.RELEASE</version> | ||
+ | </dependency> | ||
+ | <dependency> | ||
+ | <groupId>org.apache.kafka</groupId> | ||
+ | <artifactId>kafka-clients</artifactId> | ||
+ | <version>1.0.1</version> | ||
+ | </dependency> | ||
+ | |||
+ | <!-- fastjson --> | ||
+ | <dependency> | ||
+ | <groupId>com.alibaba</groupId> | ||
+ | <artifactId>fastjson</artifactId> | ||
+ | <version>1.1.15</version> | ||
+ | </dependency> | ||
+ | |||
+ | </dependencies> | ||
+ | |||
+ | <build> | ||
+ | <plugins> | ||
+ | <plugin> | ||
+ | <groupId>org.springframework.boot</groupId> | ||
+ | <artifactId>spring-boot-maven-plugin</artifactId> | ||
+ | <configuration> | ||
+ | <layout>ZIP</layout> | ||
+ | <!-- <jvmArguments> -Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005 | ||
+ | </jvmArguments> --> | ||
+ | </configuration> | ||
+ | <executions> | ||
+ | <execution> | ||
+ | <goals> | ||
+ | <goal>repackage</goal> | ||
+ | </goals> | ||
+ | </execution> | ||
+ | </executions> | ||
+ | </plugin> | ||
+ | <plugin> | ||
+ | <groupId>com.github.eirslett</groupId> | ||
+ | <artifactId>frontend-maven-plugin</artifactId> | ||
+ | <version>1.6</version> | ||
+ | <configuration> | ||
+ | <nodeVersion>v8.11.1</nodeVersion> | ||
+ | </configuration> | ||
+ | <executions> | ||
+ | <execution> | ||
+ | <id>install-npm</id> | ||
+ | <phase>none</phase> | ||
+ | <goals> | ||
+ | <goal>install-node-and-npm</goal> | ||
+ | </goals> | ||
+ | </execution> | ||
+ | <execution> | ||
+ | <id>npm-install</id> | ||
+ | <phase>none</phase> | ||
+ | <goals> | ||
+ | <goal>npm</goal> | ||
+ | </goals> | ||
+ | </execution> | ||
+ | <execution> | ||
+ | <id>npm-build</id> | ||
+ | <phase>none</phase> | ||
+ | <goals> | ||
+ | <goal>npm</goal> | ||
+ | </goals> | ||
+ | <configuration> | ||
+ | <arguments>run-script build</arguments> | ||
+ | </configuration> | ||
+ | </execution> | ||
+ | </executions> | ||
+ | </plugin> | ||
+ | </plugins> | ||
+ | </build> | ||
+ | |||
+ | </project> | ||
+ | </code> | ||
+ |