Kafka mavzusiga texnik tarzda xabar yuborish qanday amalga oshiriladi? Buning uchun qaysi sinf ishlatiladi?

Kafka mavzusiga xabar yuborish texnik jihatdan ishlab chiqaruvchi (producer) yordamida amalga oshiriladi. Masalan, Java tilida bu Apache Kafka kutubxonasidan KafkaProducer sinfidir.

Xabar yuborish misoli:

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);
ProducerRecord<String, String> record = new ProducerRecord<>("mavzuNomi", "kalit", "xabar qiymati");
producer.send(record);
producer.close();

Shunday qilib, KafkaProducer sinfi Kafka mavzulariga xabar yuborish uchun javobgardir.