Kas sa töötasid Kafka-ga Springi kaudu või otse?

Olen töötanud nii Spring Kafka kui otse Kafka API-ga. Spring Kafka kasutamine lihtsustab integratsiooni, pakkudes mugavaid annotatsioone (@KafkaListener, @KafkaTemplate) ja konfiguratsiooni haldust Spring Booti kaudu. Otsekontakt Kafka-ga nõuab töötamist KafkaProducer ja KafkaConsumer-iga, mis annab suurema kontrolli, kuid nõuab rohkem koodi ja seadistusi.

Näide sõnumi saatmisest Spring Kafka abil:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Näide sõnumite vastuvõtmisest:

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