Туурасыңбы, Kafka'ны керектүү тараптан өз ара аракеттенүүнү ишке ашыруу үчүн колдондуңбу?

Ооба, мен Kafka'ны колдонуучу катары колдонуп, темалардан билдирүүлөрдү алгам. Адатта, колдонуучу тарапта Kafka Consumer конфигурацияланат, ал керек болгон темаларга жазылат жана келип түшкөн билдирүүлөрдү реалдуу убакытта иштетет.

Javaда 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());
        // бул жерде билдирүүнү иштетүү логикасы
    }
}

Бул ыкма иш-чара агымдарынан маалыматтарды асинхрон жана ишенимдүү кабыл алуу жана иштетүүгө мүмкүндүк берет.