springboot结合kafka同步发送消息

Spring Boot 结合 Apache Kafka 实现消息同步发送的过程主要包括以下几个步骤：

1. 添加依赖：在你的 Spring Boot 项目中，首先需要添加 Kafka 的客户端库和 Spring Cloud Stream 或者 Spring Integration 的依赖。例如，如果你使用的是 Maven，可以在 `pom.xml` 文件中加入以下依赖：

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

2. 配置应用：在 `application.properties` 或 `application.yml` 中配置 Kafka 主题、bootstrap servers（Kafka 服务地址）、分区数等信息。例如：

   spring.cloud.stream.bindings.output.destination=myTopic
   spring.kafka.bootstrap-servers=localhost:9092

3. 创建生产者：在 Spring Boot 的组件中，创建一个 Kafka 消息生产者的 Bean，并通过 `@EnableBinding` 注解将它绑定到输出通道（binding）。示例代码如下：

   @Component
   @EnableBinding(Sink.class)
   public class KafkaProducer {
       @Bean
       @InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000"))
       public MessageSource<String> sendMessage() {
           return () -> new GenericMessage<>("Hello from Kafka");
       }
   
       // 可能还需要一个模板来处理更复杂的发送逻辑
       @Autowired
       private KafkaTemplate<String, String> kafkaTemplate;
   }

   public interface Sink {
       @Input("input")
       SubscribableChannel input();
       @Output("output")
       MessageChannel output();
   }

4. 发送消息：当启动应用时，`sendMessage()` 方法会定期从输入通道获取消息并发送到 Kafka 的指定主题。