Աշխատե՞լ եք RabbitMQ-ով — ունե՞ք փորձ Kafka-ով։

Այո, ես ունեմ փորձ Kafka-ով աշխատելու։ Բաղդատելով RabbitMQ-ի, որը կենտրոնացած է հաղորդագրությունների հերթերի վրա և ապահովում է հուսալի առաքում հաստատումներով, Kafka-ն մի բաժանված տվյալների հոսքի հարթակ է, որը լավ է հարմար մեծ քանակությամբ իրադարձությունների իրական ժամանակում մշակման համար։

Օրինակ, իմ նախագծերից մեկում ես կազմաձևել եմ Kafka արտադրողներ և սպառողներ՝ հաղորդագրությունների և մետրիակների փոխանցման համար միկրոսերվիսներից մոնիտորինգի համակարգ։ Ես օգտագործել եմ մի քանի բաժանման թեմաներ՝ ընդլայնման համար և ապահովել հաղորդագրությունների մշակումը սպառողների խմբերի միջոցով։

Նմուշ Java-ով Kafka Producer API-ով պարզ արտադրողի օրինակ՝

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

KafkaProducer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<>("my-topic", "key1", "value1"));
producer.close();

Այսպիսով, Kafka-ն թույլ է տալիս արդյունավետ մշակել մեծ տվյալների հոսքերը՝ բարձր հոսքային կարողությամբ և ցածր ուշացումով։