springboot kafka怎么使用?
时间: 2025-01-22 12:12:04 浏览: 39
### 配置依赖
为了在Spring Boot项目中集成Apache Kafka,在`pom.xml`文件中加入必要的Maven依赖[^1]。
```xml
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
```
### 应用配置属性设置
接着,通过修改`application.properties`或`application.yml`来定义Kafka连接器所需的参数。
对于`application.properties`:
```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
```
### 创建生产者服务类
编写用于发送消息到指定主题的服务组件。下面展示了一个简单的例子,其中包含了向特定主题发布字符串消息的方法。
```java
@Service
public class KafkaProducerService {
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
public void sendMessage(String topicName, String message){
this.kafkaTemplate.send(topicName,message);
}
}
```
### 定义消费者监听方法
利用`@KafkaListener`注解可以轻松创建接收来自某个主题的消息处理器函数。这里给出一段示范代码片段,它会打印接收到的信息至控制台日志输出。
```java
@Component
public class KafkaConsumerListener {
@KafkaListener(topics = "test-topic", groupId = "my-group")
public void listen(String message) {
System.out.println("Received Message: " + message);
}
}
```
以上就是关于怎样借助Spring Boot框架快速搭建起支持基本功能的Kafka客户端应用程序的大致流程说明。
阅读全文
相关推荐


















