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 темаларына билдирүүлөрдү жөнөтүү үчүн жооптуу.