1. 添加依赖

   <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka-clients</artifactId>
       <version>{version}</version>
   </dependency>

2. 编写发送实现

   import org.apache.kafka.clients.producer.KafkaProducer;
   import org.apache.kafka.clients.producer.ProducerRecord;
   import org.springframework.stereotype.Service;

   import java.util.Properties;

   @Service
   public class KafkaProducerService {
       public void sendMessage(String topic, String message) {
           Properties props = new Properties();
           props.put("bootstrap.servers", "localhost:9092");
           props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
           props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

           KafkaProducer<String, String> producer = new KafkaProducer<>(props);
           producer.send(new ProducerRecord<>(topic, message));
           producer.close();
       }
   }

3. 发送消息，此处利用接口形式进行发送。

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

@RestController
public class KafkaProducerController {

    @Autowired
    private KafkaProducerService kafkaProducerService;

    @GetMapping("/sendMessage")
    public String sendMessage() {
        String topic = "messageTopic";
        String message = "Hello, Kafka!";
        kafkaProducerService.sendMessage(topic, message);
        return "success";
    }
}