Kā tehniski nosūtīt ziņu uz Kafka tēmu? Kurš klases izmantošanai tas ir?

Lai nosūtītu ziņu uz Kafka tēmu, tehniski tiek izmantots producents (producer). Piemēram, Java valodā tas ir KafkaProducer klases no Apache Kafka bibliotēkas.

Ziņas sūtīšanas piemērs:

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<>("temasNosaukums", "atslēga", "ziņasVērtība");
producer.send(record);
producer.close();

Tādējādi, KafkaProducer klase ir atbildīga par ziņu sūtīšanu uz Kafka tēmām.