¿Cómo enviar técnicamente un mensaje a un tema de Kafka? ¿Qué clase se usa para esto?

Para enviar un mensaje a un tema de Kafka, técnicamente se utiliza un productor (producer). En Java, por ejemplo, es la clase KafkaProducer de la biblioteca Apache Kafka.

Ejemplo de envío de mensaje:

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<>("nombreDelTema", "clave", "valor del mensaje");
producer.send(record);
producer.close();

De esta manera, la clase KafkaProducer es responsable de enviar mensajes a los temas de Kafka.