Ar naudojote Kafka, kad įgyvendintumėte sąveiką iš vartotojo pusės?

Taip, aš naudoju Kafka kaip vartotoją, kad gauti žinutes iš temų. Paprastai vartotojo pusėje konfigūruojamas Kafka Consumer, kuris prenumeruoja reikalingas temas ir apdoroja gaunamas žinutes realiu laiku.

Pavyzdys Java kalba naudojant Kafka Consumer API:

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());
        // čia žinutės apdorojimo logika
    }
}

Šis požiūris leidžia asinchroniškai ir patikimai gauti ir apdoroti duomenis iš įvykio srautų.