springboot kafka 发送消息

在 Spring Boot 中使用 Kafka 发送消息可以通过以下步骤进行：

1. 添加 Kafka 依赖

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

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

2. 配置 Kafka

在 `application.properties` 文件中添加以下配置：

spring.kafka.bootstrap-servers=localhost:9092

3. 创建生产者

在 Spring Boot 中，可以使用 `KafkaTemplate` 类来创建生产者。首先，在配置类中创建一个 `KafkaTemplate` Bean：

@Configuration
@EnableKafka
public class KafkaConfig {

  @Value("${spring.kafka.bootstrap-servers}")
  private String bootstrapServers;

  @Bean
  public KafkaTemplate<String, String> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
  }

  @Bean
  public ProducerFactory<String, String> producerFactory() {
    return new DefaultKafkaProducerFactory<>(producerConfigs());
  }

  @Bean
  public Map<String, Object> producerConfigs() {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    return props;
  }
}

注意：在上面的代码中，我们使用了 `@Value` 注解来获取 `bootstrap-servers` 配置，这是因为 Spring Boot 支持从 `application.properties` 文件中读取配置。

4. 发送消息

现在我们可以在需要发送消息的地方注入 `KafkaTemplate` 类，并使用 `send` 方法发送消息：

@Service
public class MyService {
  
  @Autowired
  private KafkaTemplate<String, String> kafkaTemplate;

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

在上面的代码中，我们使用 `kafkaTemplate.send` 方法发送消息到名为 `my-topic` 的主题中。

这就是 Spring Boot 中使用 Kafka 发送消息的基本步骤。