Kas kasutasite Kafka-t, et rakendada suhtlust tarbija poolelt?

Jah, ma olen kasutanud Kafka't kui tarbijat, et saada sõnumeid teemadest. Tavaliselt konfigureeritakse tarbija poolel Kafka Consumer, mis tellib vajalikud teemad ja töötleb saabunud sõnumeid reaalajas.

Näide Java's kasutades Kafka Consumer API'd:

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());
        // siin sõnumi töötlemise loogika
    }
}

See lähenemine võimaldab andmeid sündmuste voogudest asünkroonselt ja usaldusväärselt vastu võtta ja töödelda.