spring整合kafka

Spring可以通过Spring Kafka模块轻松地集成Kafka。Spring Kafka模块提供了简单的API来发送和接收消息，并且还包含了许多与Kafka相关的功能，如KafkaTemplate和KafkaListener注解。

以下是使用Spring Kafka模块集成Kafka的步骤：

添加Spring Kafka依赖

添加以下依赖到你的Spring应用程序的pom.xml文件中：

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

配置Kafka连接

在你的应用程序的application.properties或application.yml文件中添加以下Kafka连接配置：

spring.kafka.bootstrap-servers=<kafka-server>:<port>
spring.kafka.consumer.group-id=<group-id>

发送消息

使用KafkaTemplate来发送消息。KafkaTemplate是一个Spring Kafka提供的高级工具，它封装了Kafka的生产者API，使得发送消息变得更加简单。

例如，以下代码演示如何使用KafkaTemplate发送消息：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

接收消息

使用@KafkaListener注解来接收消息。@KafkaListener注解将一个方法标记为Kafka消费者，并指定要监听的主题和分组。

例如，以下代码演示了如何使用@KafkaListener注解来接收消息：

@KafkaListener(topics = "topic-name", groupId = "group-id")
public void receiveMessage(String message) {
    System.out.println("Received message: " + message);
}

以上是使用Spring Kafka模块集成Kafka的基本步骤。你可以根据你的需求进一步深入学习和使用Spring Kafka模块。