Tüketici tarafında etkileşimi uygulamak için Kafka kullandınız mı?

Evet, Kafka'yı mesajları konu başlıklarından almak için tüketici olarak kullandım. Genellikle tüketici tarafında, ihtiyaç duyulan konulara abone olan ve gelen mesajları gerçek zamanlı işleyen Kafka Tüketicisi yapılandırılır.

Java'da Kafka Consumer API kullanarak örnek:

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 işleme mantığı
    }
}

Bu yaklaşım, olay akışlarından gelen verileri asenkron ve güvenilir bir şekilde almak ve işlemek için olanak tanır.