Kafka ilə Spring vasitəsilə və ya birbaşa işlədinizmi?

Mən həm Spring Kafka ilə, həm də birbaşa Kafka API ilə işlədim. Spring Kafka istifadəsi inteqrasiyanı sadələşdirir, rahat anotasiya (@KafkaListener, @KafkaTemplate) və Spring Boot vasitəsilə konfiqurasiya idarəsini təmin edir. Birbaşa Kafka ilə işləmək KafkaProducer və KafkaConsumer ilə işləməyi tələb edir, bu isə daha çox nəzarət imkanı verir, lakin daha çox kod və konfiqurasiya tələb edir.

Spring Kafka vasitəsilə mesaj göndərmə nümunəsi:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Mesajların qəbul nümunəsi:

@KafkaListener(topics = "myTopic", groupId = "group_id")
public void listen(String message) {
    System.out.println("Qəbul edildi: " + message);
}