Оё шумо Kafka-ро барои иҷрои ҳамкории тарафи истеъмолкунанда истифода бурдед?

Бале, ман Kafka-ро ҳамчун истеъмолкунанда барои гирифтани паёмҳо аз мавзӯъҳо истифода кардам. Одатан, дар ҷониби истеъмолкунанда, Kafka Consumer танзим карда мешавад, ки ба мавзӯъҳои зарурӣ обуна мешавад ва паёмҳои воридшударо дар вақти воқеӣ коркард мекунад.

Масалан дар Java бо истифода аз API Kafka Consumer:

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());
        // дар ин ҷо логикаи коркарди паём
    }
}

Ин усул имкон медиҳад, ки маълумотҳоро аз ҷараёнҳои ҳодисаҳо ба таври асинхрон ва боэътимод қабул ва коркард кард.