spring+kafka 整合

Spring和Kafka的整合是非常常见的，因为Spring提供了与Kafka集成的库，并且可以方便地在Spring应用程序中使用Kafka作为消息传递系统。

下面是一个简单的Spring和Kafka整合的步骤：

添加Kafka依赖

在Spring Boot应用程序中使用Kafka，需要添加以下依赖：

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

创建Kafka生产者

在Spring中，可以使用KafkaTemplate类创建Kafka生产者。KafkaTemplate是一个泛型类，需要指定键和值的类型。

以下是一个创建Kafka生产者的例子：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

创建Kafka消费者

可以使用@KafkaListener注解创建Kafka消费者。@KafkaListener注解需要指定要监听的主题和用于处理消息的方法。

以下是一个创建Kafka消费者的例子：

@KafkaListener(topics = "test")
public void handleMessage(String message) {
    System.out.println("Received message: " + message);
}

配置Kafka连接

在应用程序的application.properties或application.yml文件中，需要配置Kafka连接信息，例如：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group

以上就是一个简单的Spring和Kafka整合的例子。可以根据实际需求进行扩展和调整。