Pracovali ste s Kafka cez Spring alebo priamo?

Pracoval som s Spring Kafka aj priamo s Kafka API. Použitie Spring Kafka zjednodušuje integráciu, poskytuje pohodlné anotácie (@KafkaListener, @KafkaTemplate) a správu konfigurácie cez Spring Boot. Priamy kontakt s Kafka vyžaduje prácu s KafkaProducer a KafkaConsumer, čo dáva väčšiu kontrolu, ale vyžaduje viac kódu a nastavení.

Príklad odoslania správy cez Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Príklad príjmu správ:

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