springboot结合kafka异步发送消息

Spring Boot 结合 Apache Kafka 异步发送消息通常涉及到以下几个步骤：

1. **添加依赖**：首先，在你的Spring Boot项目中添加Kafka和相关Spring Cloud Stream依赖到`pom.xml`或`build.gradle`文件中。

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

<!-- Gradle (example) -->
implementation 'org.springframework.cloud:spring-cloud-stream'
implementation 'org.springframework.cloud:spring-cloud-stream-binder-kafka'

2. **配置Kafka**：在application.yml或application.properties文件里配置Kafka的连接信息，包括bootstrap servers地址等。

spring:
  cloud:
    stream:
      bindings:
        input-topic:
          destination: your-input-topic
        output-topic:
          destination: your-output-topic
      kafka:
        consumer:
          bootstrap-servers: localhost:9092
        producer:
          bootstrap-servers: localhost:9092
          key-serializer: org.apache.kafka.common.serialization.StringSerializer
          value-serializer: org.apache.kafka.common.serialization.StringSerializer

3. **创建生产者或消费者**：定义一个处理消息发送的类，并使用`@KafkaListener`或`@SendTo`注解来处理异步消息。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
public class MyKafkaProducer {

    private final KafkaTemplate<String, String> kafkaTemplate;

    @Autowired
    public MyKafkaProducer(KafkaTemplate<String, String> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }

    @KafkaListener(topics = "your-input-topic")
    public void sendMessage(String message) {
        kafkaTemplate.send("your-output-topic", message);
    }
}

在这个例子中，`MyKafkaProducer`监听指定输入主题的消息，然后将其发送到另一个输出主题。

4. **启动应用**：启动Spring Boot应用，它会自动创建Kafka消费者和生产者，并按照配置进行消息交互。