springboot2.6整合kafka
时间: 2023-09-03 21:15:19 浏览: 97
Spring Boot 2.6 与 Kafka 的集成非常简单,只需要在项目中添加 Kafka 相关依赖,然后配置 Kafka 的连接信息即可。
以下是 Spring Boot 2.6 整合 Kafka 的步骤:
1. 添加 Kafka 依赖
在 pom.xml 文件中添加 Kafka 相关依赖:
```xml
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.7.3</version>
</dependency>
```
2. 配置 Kafka 连接信息
在 application.properties 或 application.yml 文件中添加 Kafka 连接信息:
```yaml
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
```
其中,`bootstrap-servers` 是 Kafka 服务器地址;`consumer.group-id` 是消费者组 ID;`producer.key-serializer` 和 `producer.value-serializer` 是序列化器。
3. 创建 Kafka 生产者
在代码中创建 Kafka 生产者:
```java
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;
@Component
public class KafkaProducer {
private final KafkaTemplate<String, String> kafkaTemplate;
public KafkaProducer(KafkaTemplate<String, String> kafkaTemplate) {
this.kafkaTemplate = kafkaTemplate;
}
public void sendMessage(String topic, String message) {
kafkaTemplate.send(topic, message);
}
}
```
在构造函数中注入 `KafkaTemplate`,然后在 `sendMessage` 方法中发送消息。
4. 创建 Kafka 消费者
在代码中创建 Kafka 消费者:
```java
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
@Component
public class KafkaConsumer {
@KafkaListener(topics = "my-topic", groupId = "my-group")
public void handleMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
使用 `@KafkaListener` 注解监听主题,并在方法中处理消息。
至此,Spring Boot 2.6 整合 Kafka 的步骤就完成了。你可以通过调用 KafkaProducer 的 sendMessage 方法向 Kafka 发送消息,也可以通过监听 Kafka 主题来消费消息。