springboot集成kafka生产者

要在springboot中集成kafka生产者，需要遵循以下步骤：

1. 添加Maven依赖

在pom.xml文件中添加以下依赖：

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

2. 配置Kafka生产者

在application.properties文件中添加Kafka的配置：

spring.kafka.producer.bootstrap-servers=<broker地址>
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

3. 创建Kafka生产者

在代码中创建Kafka生产者：

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

@Service
public class KafkaProducerService {

    private final KafkaTemplate<String, String> kafkaTemplate;

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

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

}

4. 发送消息

在需要发送消息的地方，注入KafkaProducerService，并调用sendMessage方法：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MessageController {

    private final KafkaProducerService kafkaProducerService;

    @Autowired
    public MessageController(KafkaProducerService kafkaProducerService) {
        this.kafkaProducerService = kafkaProducerService;
    }

    @PostMapping("/message")
    public void sendMessage(@RequestBody String message) {
        this.kafkaProducerService.sendMessage("test-topic", message);
    }

}

以上就是在springboot中集成Kafka生产者的步骤。