Junior — Middle
Usou Kafka para implementar a interação do lado do consumidor?
sobes.tech IA
Resposta da IA
Sim, utilizei o Kafka como consumidor para receber mensagens dos tópicos. Normalmente, do lado do consumidor, configura-se um Kafka Consumer, que se inscreve nos tópicos necessários e processa as mensagens recebidas em tempo real.
Exemplo em Java usando a API Kafka Consumer:
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("my-topic"));
while (true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records) {
System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
// lógica de processamento da mensagem aqui
}
}
Este método permite receber e processar dados de fluxos de eventos de forma assíncrona e confiável.