springboot kafka如何快速搭建

在Spring Boot項目中快速搭建Kafka集成，可以通過以下步驟實現：

添加依賴

首先，在項目的pom.xml文件中添加Spring Kafka的依賴項。確保版本與Spring Boot版本兼容。

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.7.2</version> <!-- 使用與Spring Boot版本兼容的版本 -->
</dependency>

配置Kafka

在application.yml或application.properties文件中配置Kafka連接信息，包括bootstrap-servers、group-id、key-deserializer、value-deserializer等。

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      group-id: my-consumer-group
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

創建生產者和消費者

創建一個生產者類，使用KafkaTemplate發送消息到Kafka主題。創建一個消費者類，使用@KafkaListener注解監聽特定主題的消息。

生產者示例代碼

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

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

消費者示例代碼

@Service
public class KafkaConsumer {
    @KafkaListener(topics = "my-topic", groupId = "my-consumer-group")
    public void consumeMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

啟動和測試

啟動Spring Boot應用程序，發送和接收消息以測試集成是否成功。

以上步驟提供了在Spring Boot項目中快速搭建Kafka集成的完整流程。確保所有配置正確無誤，并根據實際項目需求調整配置參數。