Как технически да изпратите съобщение в 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 теми.