Kafka 入门实战(3)-
spring-kafka 使得在 Spring 环境中使用 Kafka 变的很简单,只需少量的配置和少量的代码就可以发送和接受消息了。本文主要介绍在 SpringBoot 中用 spring-kafka 操作 Kafka,文中使用到的软件版本:Kafka 2.8.0、SpringBoot 2.4.6、Java 1.8.0_191。
1、参数说明
spring-kafka 中参数是以 spring.kafka 开头的,后面的参数名称和 Kafka 的原始参数很类似,只不过 spring-kafka 会把一些参数中的 “.” 改为 “-“,如 auto.offset.reset 改为 spring.kafka.consumer.auto-offset-reset。
前缀 | 描述 |
spring.kafka | Spring 中 Kafka 相关配置总的前缀 |
spring.kafka.consumer | 消费者相关参数 |
spring.kafka.producer | 生产者相关参数 |
spring.kafka.admin | Kafka 管理相关参数 |
kafka 的原始参数说明可参考:Kafka入门实战(1)-概念、安装及简单使用;或参考官方文档。
2、SpringBoot 整合 Kafka
2.1、引入依赖
<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> </dependency> <!--流处理需要用到--> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> </dependency>