springboot整合kafka消费端
时间: 2023-04-22 22:06:36 浏览: 180
Spring Boot可以很方便地整合Kafka消费端,具体步骤如下:
1. 添加Kafka依赖
在pom.xml文件中添加Kafka依赖:
```
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.7.2</version>
</dependency>
```
2. 配置Kafka消费者
在application.properties文件中配置Kafka消费者相关属性:
```
spring.kafka.consumer.bootstrap-servers=<kafka服务器地址>
spring.kafka.consumer.group-id=<消费者组ID>
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
```
3. 创建Kafka消费者
使用@KafkaListener注解创建Kafka消费者,示例代码如下:
```
@Component
public class KafkaConsumer {
@KafkaListener(topics = "<topic名称>")
public void consume(String message) {
System.out.println("Received message: " + message);
}
}
```
4. 运行程序
启动Spring Boot应用程序,Kafka消费者会自动从指定的Kafka主题中消费消息。
以上就是Spring Boot整合Kafka消费端的基本步骤,希望对你有所帮助。
阅读全文