springboot集成kafka(手把手教你5步搞定)

在Spring Boot中集成Kafka相对简单，以下是springboot集成kafka的5大详细步骤@mikechen

1.添加依赖

在pom.xml文件中添加Kafka的Spring Boot Starter依赖。

如下所示：

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

2.配置Kafka连接

在application.properties，或application.yml文件中配置Kafka连接信息。

如下所示：

spring.kafka.bootstrap-servers=<Kafka服务器地址>
spring.kafka.consumer.group-id=<消费者组ID>

3.创建生产者

创建KafkaTemplate bean，用于发送消息到Kafka。

如下所示：

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

@Component
public class KafkaProducer {
    
    private final KafkaTemplate<String, String> kafkaTemplate;

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

    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

4.创建消费者

创建KafkaListener bean，并指定监听的主题和处理逻辑。

如下所示：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {

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

5.发送和接收消息

在需要发送或接收消息的地方使用生产者和消费者组件。

如下所示：

@Autowired
private KafkaProducer kafkaProducer;

public void sendMessageToKafka() {
    kafkaProducer.sendMessage("<主题名称>", "Hello, Kafka!");
}

请根据实际情况替换 <Kafka服务器地址>、<消费者组ID>、<主题名称> 等参数，并根据自己的业务逻辑进行相应的扩展和处理。

以上是基本的集成步骤，还可以根据需求使用更多的Kafka配置和特性，如消息确认机制、自定义序列化器、分区策略等。详细的配置和使用方法可以参考Spring Kafka的官方文档或相关教程。