Чӣ тавр ба таври техникӣ паёмро ба мавзӯи Kafka фиристодан мумкин аст? Барои ин кадом синф истифода мешавад?

Барои фиристодани паём ба мавзӯи Kafka, техникӣ истифода мешавад истеҳсолкунанда (producer). Дар Java, масалан, ин синфи KafkaProducer аз китобхонаи Apache Kafka мебошад.

Масали фиристодани паём:

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<>("номиМавзӯъ", "калид", "қиматиПаём");
producer.send(record);
producer.close();

Тавре ки мебинем, синфи KafkaProducer масъул аст барои фиристодани паёмҳо ба мавзӯъҳои Kafka.