Kafka 入门实战(3)-

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>
hmoban主题是根据ripro二开的主题,极致后台体验,无插件,集成会员系统
自学咖网 » Kafka 入门实战(3)-