Sobes.tech
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.