给我找找springboot整合kafka的
时间: 2023-11-02 09:14:14 浏览: 38
Sure, 您可以参考下面的步骤进行Spring Boot与Kafka的整合:
1. 添加Spring Kafka依赖:
```xml
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.3.3.RELEASE</version>
</dependency>
```
2. 配置Kafka:
```yaml
spring:
kafka:
bootstrap-servers: localhost:9092
producer:
value-serializer: org.apache.kafka.common.serialization.StringSerializer
consumer:
group-id: my-group
auto-offset-reset: earliest
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
```
3. 创建Kafka生产者:
```java
@Service
public class KafkaProducerService {
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
public void send(String topic, String data) {
kafkaTemplate.send(topic, data);
}
}
```
4. 创建Kafka消费者:
```java
@Service
public class KafkaConsumerService {
@KafkaListener(topics = "test-topic", groupId = "my-group")
public void listen(String message) {
System.out.println("Received Message: " + message);
}
}
```
以上就是整合Spring Boot和Kafka的基本步骤与代码示例。