spring cloud集成kafka并消费

Spring Cloud Kafka是一个基于Spring框架的扩展模块，用于简化在分布式系统中集成Apache Kafka的过程。它提供了一种简单的方式来创建Kafka消费者和生产者，同时支持高级特性如事务、消息确认、自动分区分配等。

以下是使用Spring Cloud Kafka在Spring Boot应用中集成Kafka并消费的基本步骤：

1. 添加依赖：在`pom.xml`文件中添加Spring Cloud Stream和Spring Cloud Kafka的相关依赖。

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

2. 配置Kafka连接信息：在`application.properties`或`application.yml`中配置Kafka服务器地址、bootstrap servers等信息。

spring.cloud.stream.bindings.input.destination=my-topic
spring.kafka.bootstrap-servers=localhost:9092

3. 创建消费者：在Spring组件扫描的类上声明`@StreamListener`注解，指定输入绑定（destination）。

@Component
public class MyConsumer {

    @StreamListener("input")
    public void consume(String message) {
        System.out.println("Received message: " + message);
    }
}

4. 发布消息：如果你想从其他地方发布消息到Kafka，可以使用`KafkaTemplate`，也可以通过其他支持Kafka的消息发送方式。