Sobes.tech
Middle

Czy pracowałeś z Kafka przez Spring czy bezpośrednio?

sobes.tech AI

Odpowiedź od AI

Pracowałem zarówno z Spring Kafka, jak i bezpośrednio z API Kafka. Użycie Spring Kafka upraszcza integrację, zapewniając wygodne adnotacje (@KafkaListener, @KafkaTemplate) i zarządzanie konfiguracją przez Spring Boot. Bezpośrednia interakcja z Kafka wymaga pracy z KafkaProducer i KafkaConsumer, co daje większą kontrolę, ale wymaga więcej kodu i konfiguracji.

Przykład wysyłania wiadomości przez Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Przykład odbioru wiadomości:

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