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。

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>