springboot中kafka的配置

在Spring Boot中配置Kafka需要以下步骤:

1. 在pom.xml中添加Kafka的依赖：

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

2. 在application.properties或application.yml中配置Kafka服务器地址：

spring.kafka.bootstrap-servers=kafka服务器地址:端口

3. 创建一个KafkaTemplate类，用于发送消息：

@Component
public class KafkaSender {
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

4. 创建一个Kafka消费者，用于接收消息：

@Component
public class KafkaConsumer {
    @KafkaListener(topics = {"topic名称"})
    public void receive(ConsumerRecord<?, ?> record) {
        System.out.println("消息内容：" + record.value());
    }
}

这是在Spring Boot中配置Kafka的简单示例，您可以根据需要进行修改和扩展。