Hai lavorato con Kafka tramite Spring o direttamente?

Ho lavorato sia con Spring Kafka che direttamente con l'API Kafka. L'uso di Spring Kafka semplifica l'integrazione, fornendo annotazioni utili (@KafkaListener, @KafkaTemplate) e la gestione della configurazione tramite Spring Boot. L'interazione diretta con Kafka richiede di lavorare con KafkaProducer e KafkaConsumer, offrendo più controllo, ma richiede più codice e configurazione.

Esempio di invio di un messaggio tramite Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Esempio di consumo di messaggi:

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