Middle
Como enviar tecnicamente uma mensagem para um tópico Kafka? Qual classe usar para isso?
sobes.tech IA
Resposta da IA
Para enviar uma mensagem para um tópico Kafka, tecnicamente usa-se um produtor (producer). Em Java, por exemplo, é a classe KafkaProducer da biblioteca Apache Kafka.
Exemplo de envio de mensagem:
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<>("nomeDoTopico", "chave", "valor da mensagem");
producer.send(record);
producer.close();
Assim, a classe KafkaProducer é responsável por enviar mensagens aos tópicos Kafka.