İstehlakçı tərəfdən qarşılıqlı əlaqəni həyata keçirmək üçün Kafka istifadə etdinizmi?

Bəli, mən Kafka'yı mesajları mövzularından almaq üçün istehlakçı kimi istifadə etmişəm. Adətən, istehlakçı tərəfində Kafka Consumer qurulur, lazım olan mövzulara abunə olur və daxil olan mesajları real vaxtda emal edir.

Java'da Kafka Consumer API istifadə edərək nümunə:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("my-topic"));

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
        // burada mesajın emalı üçün loqika
    }
}

Bu yanaşma, hadisə axınlarından məlumatları asinxron və etibarlı şəkildə almağa və emal etməyə imkan verir.