Kafka'da bir konuya mesaj göndermenin teknik yolu nedir? Bunun için hangi sınıf kullanılır?

Kafka konuya mesaj göndermek teknik olarak bir üretici (producer) kullanılır. Örneğin Java'da, bu Apache Kafka kütüphanesinden KafkaProducer sınıfıdır.

Mesaj gönderme örneği:

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<>("konuAdi", "anahtar", "mesaj değeri");
producer.send(record);
producer.close();

Bu şekilde, KafkaProducer sınıfı Kafka konularına mesaj göndermekle sorumludur.