springboot中kafka工具类
时间: 2023-11-20 16:54:59 浏览: 43
在Spring Boot中使用Kafka,可以使用Spring Kafka提供的KafkaTemplate来发送和接收消息。下面是一个简单的Kafka工具类的示例:
```java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;
@Component
public class KafkaProducer {
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
public void sendMessage(String topic, String message) {
kafkaTemplate.send(topic, message);
}
}
@Component
public class KafkaConsumer {
@KafkaListener(topics = "${spring.kafka.topic}")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
在上面的代码中,KafkaProducer类使用@Autowired注解注入了KafkaTemplate,然后可以使用sendMessage方法来发送消息。KafkaConsumer类使用@KafkaListener注解来监听指定的主题,并在接收到消息时打印出来。
相关推荐
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)