Spring Boot 集成 Kafka

Spring Boot可以轻松地集成Kafka，使得应用程序可以轻松地使用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
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

3. 创建生产者

创建一个Kafka生产者，用于将消息发送到Kafka中：

@Service
public class KafkaProducerService {
    
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;
    
    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

4. 创建消费者

创建一个Kafka消费者，用于从Kafka中接收消息：

@Service
public class KafkaConsumerService {
    
    @KafkaListener(topics = "my-topic")
    public void listen(String message) {
        System.out.println("Received message: " + message);
    }
}

5. 发送和接收消息

在应用程序中使用KafkaProducerService发送消息，使用KafkaConsumerService接收消息：

@Autowired
private KafkaProducerService kafkaProducerService;

public void sendMessage() {
    kafkaProducerService.sendMessage("my-topic", "Hello Kafka!");
}

6. 运行应用程序

运行应用程序，发送和接收Kafka消息。

以上就是Spring Boot集成Kafka的步骤。通过使用Spring Boot和Kafka，可以轻松地构建可扩展的应用程序。