Πώς στέλνετε τεχνικά ένα μήνυμα σε ένα θέμα 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.