Vai strādāji ar Kafka caur Spring vai tieši?

Es strādājis gan ar Spring Kafka, gan tieši ar Kafka API. Spring Kafka izmantošana vienkāršo integrāciju, nodrošinot ērtas anotācijas (@KafkaListener, @KafkaTemplate) un konfigurācijas pārvaldību caur Spring Boot. Tieša ar Kafka saistīta darbība prasa strādāt ar KafkaProducer un KafkaConsumer, kas dod vairāk kontroli, bet prasa vairāk koda un konfigurācijas.

Piemērs, kā nosūtīt ziņojumu ar Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Piemērs, kā saņemt ziņojumus:

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