springboot kafka 同步发消息

使用Spring Boot与Kafka进行同步消息发送可以通过以下步骤实现：

1. 首先，在pom.xml文件中添加Kafka客户端依赖：

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

2. 在application.properties文件中配置Kafka连接信息：

spring.kafka.bootstrap-servers=<kafka服务器地址>

3. 创建一个消息生产者类，用于发送消息。可以使用KafkaTemplate来简化发送消息的操作。示例代码如下：

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

@Component
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

4. 在需要发送消息的地方，注入KafkaProducer并调用sendMessage方法发送消息。示例代码如下：

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

@RestController
public class MyController {

    @Autowired
    private KafkaProducer kafkaProducer;

    @GetMapping("/send")
    public String sendMessage() {
        kafkaProducer.sendMessage("myTopic", "Hello Kafka!");
        return "Message sent successfully";
    }
}