springboot使用kafaka

要在Spring Boot项目中集成Kafka，可以按照以下步骤设置：

添加依赖：
在pom.xml文件中添加Spring Kafka的依赖：
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
登录后复制

配置Kafka听众：
在配置类（如application.yml或application.properties）中，设置Kafka消费者监听器和连接信息，但避免直接使用IP地址，而是使用集群名称和端口：
spring:
kafka:
bootstrap-servers: 'kafka-cluster-name:9092'
listeners: PLAINTEXT://${spring.kafka.bootstrap-servers}
consumer:
group-id: your-consumer-group
auto-offset-reset: earliest
enable-auto-commit: ${spring.kafka.consumer.enable-auto-commit} # 可以选择性地禁用自动提交偏移量
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
登录后复制
注意替换kafka-cluster-name为实际的Kafka集群名称。

使用消息消费者：
创建一个消费Kafka消息的类，使用@KafkaListener注解来监听主题上的消息：

@Component
public class KafkaConsumer {
 @KafkaListener(topics = "your-topic", groupId = "${spring.kafka.consumer.group-id}")
 public void consume(String message) {
 // 处理接收到的消息
 }


}
这里的`your-topic`应该替换为你想要消费的主题。
登录后复制