覆盖 Spring Boot 依赖
在 Spring Boot 应用程序中使用 Spring for Apache Kafka 时,Apache Kafka 依赖版本由 Spring Boot 的依赖管理决定。如果你希望使用不同版本的 kafka-clients 或 kafka-streams,并使用嵌入式 kafka broker 进行测试,则需要覆盖 Spring Boot 依赖管理所使用的版本:设置 kafka.version 属性。
备注
Spring Boot 3.5.x 和 3.4.x 都使用 kafka-clients 3.8.x 版本,如果用户需要使用 3.9.x 客户端,则必须使用下面的方法手动升级。
或者,要在受支持的 Spring Boot 版本上使用不同版本的 Spring for Apache Kafka,请设置 spring-kafka.version 属性。
- Maven
- Gradle
<properties>
<kafka.version>4.0.0</kafka.version>
<spring-kafka.version>4.1.1</spring-kafka.version>
</properties>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
<!-- optional - only needed when using kafka-streams -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId>
<scope>test</scope>
</dependency>
ext['kafka.version'] = '3.5.0'
ext['spring-kafka.version'] = '4.1.1'
dependencies {
implementation 'org.springframework.kafka:spring-kafka'
implementation 'org.apache.kafka:kafka-streams' // optional - only needed when using kafka-streams
testImplementation 'org.springframework.kafka:spring-kafka-test'
}
test 范围的依赖仅在你在测试中使用嵌入式 Kafka broker 时才需要。