Sobes.tech
Middle

Da li ste radili sa Kafka putem Spring ili direktno?

sobes.tech АИ

Одговор од АИ

Radio sam s Spring Kafka i direktno s Kafka API-jem. Korišćenje Spring Kafka olakšava integraciju, pružajući zgodne anotacije (@KafkaListener, @KafkaTemplate) i upravljanje konfiguracijom putem Spring Boot-a. Direktna interakcija sa Kafka zahteva rad sa KafkaProducer i KafkaConsumer, što daje veću kontrolu, ali zahteva više koda i podešavanja.

Primer slanja poruke putem Spring Kafka:

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

Primer primanja poruka:

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