Ai lucrat cu Kafka prin Spring sau direct?

Am lucrat atât cu Spring Kafka, cât și direct cu API-ul Kafka. Utilizarea Spring Kafka simplifică integrarea, oferind adnotări convenabile (@KafkaListener, @KafkaTemplate) și gestionarea configurației prin Spring Boot. Interacțiunea directă cu Kafka necesită lucrul cu KafkaProducer și KafkaConsumer, ceea ce oferă mai mult control, dar necesită mai mult cod și configurare.

Exemplu de trimitere a mesajelor prin Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Exemplu de consum de mesaje:

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