springboot kafka配置

Spring Boot中使用Kafka需要进行以下配置：

1. 添加Kafka依赖

在pom.xml文件中添加以下依赖：

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

2. 配置Kafka连接信息

在application.properties文件中添加以下配置：

spring.kafka.bootstrap-servers=127...1:9092
spring.kafka.consumer.group-id=my-group

其中，bootstrap-servers指定Kafka的地址和端口，consumer.group-id指定消费者组的ID。

3. 创建Kafka生产者

使用Spring Boot的自动配置，可以通过注入KafkaTemplate来创建Kafka生产者。

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

4. 创建Kafka消费者

使用@KafkaListener注解可以创建Kafka消费者。

@KafkaListener(topics = "my-topic", groupId = "my-group")
public void receiveMessage(String message) {
    System.out.println("Received message: " + message);
}

其中，topics指定要消费的主题，groupId指定消费者组的ID。

以上就是Spring Boot中使用Kafka的配置方法。