springboot 2.7.0 整合kafka

在Spring Boot 2.7.0中，可以通过添加spring-kafka依赖库来实现与Kafka的整合。只要在项目的pom.xml文件中添加以下依赖配置即可：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

这样，Spring Boot会自动配置KafkaAdmin和KafkaTemplate，其中KafkaAdmin封装了Kafka的管理API，KafkaTemplate则提供了大量重载的send()方法用于发送消息。[1]

如果没有显式配置spring.kafka.streams.application-id属性，Spring Boot会默认使用spring.application.name属性值作为应用ID。可以通过以下配置来启用自动创建流：

spring.kafka.streams.auto-startup=true

此外，Spring Boot为Kafka流API并未提供太多额外的支持，它只提供了一个@EnableKafkaStreams注解，通过该注解能让Spring Boot自动配置StreamsBuilder，当然也能将StreamsBuilder注入任意的其他组件，剩下的事情Spring Boot就不再参与了。[3]