Работали с 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("Received: " + message);
}