Работили ли сте с Kafka чрез Spring или директно?

Работих както със Spring Kafka, така и директно с Kafka API. Използването на Spring Kafka улеснява интеграцията, предоставя удобни анотации (@KafkaListener, @KafkaTemplate) и управление на конфигурацията чрез Spring Boot. Директното взаимодействие с Kafka изисква работа с KafkaProducer и KafkaConsumer, което дава повече контрол, но изисква повече код и настройка.

Пример за изпращане на съобщение чрез Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Пример за приемане на съобщения:

@KafkaListener(topics = "myTopic", groupId = "group_id")
public void listen(String message) {
    System.out.println("Получено: " + message);
}