spring kafka sample

以下是一个简单的Spring Kafka示例：

1. 配置Kafka连接信息

spring.kafka.bootstrap-servers=<kafka服务器地址>
spring.kafka.consumer.group-id=<消费者组ID>

2. 定义Producer

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

3. 定义Consumer

@Service
public class KafkaConsumerService {
    
    @KafkaListener(topics = "<topic名称>")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

4. 发送消息

@Autowired
private KafkaProducerService kafkaProducerService;

kafkaProducerService.sendMessage("<topic名称>", "Hello Kafka!");

5. 接收消息

@Autowired
private KafkaConsumerService kafkaConsumerService;

在启动应用程序时，Spring会自动创建Kafka Producer和Consumer，并将它们注入到对应的服务中。在发送消息时，调用Kafka Producer的send()方法即可；在接收消息时，使用@KafkaListener注解表示监听指定的topic，当有消息到达时，会自动调用对应的方法进行处理。

以上就是一个简单的Spring Kafka示例，通过Spring的依赖注入和Kafka的异步消息处理，实现了高效的消息传输和处理。