kafka配置 springboot

你好！关于在Spring Boot中配置Kafka，你可以按照以下步骤进行操作：

1. 导入Kafka依赖：在你的Spring Boot项目的`pom.xml`文件中，添加以下依赖：

<dependency>
   <groupId>org.springframework.kafka</groupId>
   <artifactId>spring-kafka</artifactId>
</dependency>

2. 配置Kafka属性：在`application.properties`或`application.yml`文件中添加Kafka的连接属性，例如：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest

3. 创建生产者：使用`KafkaTemplate`类创建一个Kafka生产者，示例代码如下：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class KafkaProducerService {

   private final KafkaTemplate<String, String> kafkaTemplate;

   @Autowired
   public KafkaProducerService(KafkaTemplate<String, String> kafkaTemplate) {
       this.kafkaTemplate = kafkaTemplate;
   }

   public void sendMessage(String topic, String message) {
       kafkaTemplate.send(topic, message);
   }
}

4. 创建消费者：使用`@KafkaListener`注解创建一个Kafka消费者，示例代码如下：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class KafkaConsumerService {

   @KafkaListener(topics = "my-topic", groupId = "my-group")
   public void receiveMessage(String message) {
       System.out.println("Received message: " + message);
       // 处理收到的消息逻辑
   }
}

以上是一个简单的Kafka配置和使用示例。你可以根据自己的需求修改和扩展这些代码。希望能对你有所帮助！如有更多问题，请随时提问。