springboot 整合 kafka

SpringBoot可以很方便地与Kafka进行整合。首先，需要引入相关的依赖。在pom.xml文件中添加以下依赖项：

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

接下来，需要配置Kafka的连接信息。在application.properties或application.yml文件中添加以下配置：

spring.kafka.bootstrap-servers=<kafka地址>
spring.kafka.consumer.group-id=<消费者组ID>
spring.kafka.consumer.auto-offset-reset=earliest

然后，定义一个Kafka消息的消费者。可以使用注解@KafkaListener来监听指定的topic，并处理接收到的消息。例如：

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "<topic名称>")
    public void consumeMessage(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

最后，定义一个Kafka消息的生产者，用于发送消息。可以使用@Autowired注解来注入KafkaTemplate，并使用它发送消息。例如：

@Service
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String message) {
        kafkaTemplate.send("<topic名称>", message);
    }
}