Cum se trimite tehnic un mesaj într-un topic Kafka? Ce clasă se folosește pentru asta?

Pentru a trimite un mesaj către un topic Kafka, se folosește tehnic un producer (producător). În Java, de exemplu, aceasta este clasa KafkaProducer din biblioteca Apache Kafka.

Exemplu de trimitere a unui mesaj:

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<>("numeleTopicului", "cheie", "valoarea mesajului");
producer.send(record);
producer.close();

Astfel, clasa KafkaProducer este responsabilă pentru trimiterea mesajelor către topicurile Kafka.