kafka-入门篇springboot

Kafka是一个分布式流处理平台，由LinkedIn开发并开源，常用于构建实时数据管道和事件驱动的应用程序。它支持高吞吐量、低延迟的消息生产、消费和存储。Spring Boot是一个流行的Java框架，简化了创建独立的、自包含的微服务。

在Spring Boot中集成Kafka，你可以按照以下步骤操作：

1. 添加依赖：在`pom.xml`文件中添加Spring Kafka的依赖，例如：

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

2. 配置Kafka：在application.properties或application.yml文件中配置Kafka的相关连接信息，如bootstrap.servers、主题名等。

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.topics=myTopic

3. 创建消费者或生产者：使用Spring的`@KafkaListener`注解创建消息监听器（Consumer），或者`@KafkaProducer`注解创建生产者。

@Service
public class MyKafkaConsumer {
    @KafkaListener(topics = "myTopic")
    public void consumeMessage(String message) {
        // 处理接收到的消息
    }
}

@Service
public class MyKafkaProducer {
    private final KafkaTemplate<String, String> template;

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

    public void sendMessage(String message) {
        template.send("myTopic", message);
    }
}

4. 如果需要，可以使用@EnableKafka注解开启Kafka功能，并创建配置类配置分区策略等高级特性。