Spring аркылуу же түз эле Kafka менен иштедиңби?

Мен 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);
}