spring+kafka 1311版本 整合案例 详细点

以下是Spring和Kafka 1.3.11版本的整合案例：

1. 添加Maven依赖

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

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

2. 配置Kafka连接信息

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

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

3. 创建Kafka生产者

使用Spring Kafka提供的KafkaTemplate发送消息到Kafka：

@Service
public class KafkaProducerService {
    
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;
    
    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

4. 创建Kafka消费者

使用Spring Kafka提供的@KafkaListener注解消费消息：

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

5. 测试

在Controller中注入KafkaProducerService，并调用sendMessage方法发送消息：

@RestController
public class KafkaController {
    
    @Autowired
    private KafkaProducerService kafkaProducerService;
    
    @GetMapping("/send")
    public String sendMessage() {
        kafkaProducerService.sendMessage("my-topic", "Hello, Kafka!");
        return "Message sent";
    }
}

启动应用程序并访问/send端点，将在控制台上看到消费者接收到的消息。