Sobes.tech
Junior — Middle

¿Has utilizado Kafka para implementar la interacción desde el lado del consumidor?

sobes.tech AI

Respuesta de la IA

Sí, he utilizado Kafka como consumidor para recibir mensajes de los temas. Normalmente, en el lado del consumidor, se configura un Kafka Consumer, que se suscribe a los temas necesarios y procesa los mensajes entrantes en tiempo real.

Ejemplo en Java usando la 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());
        // aquí la lógica de procesamiento del mensaje
    }
}

Este enfoque permite recibir y procesar datos de flujos de eventos de forma asíncrona y confiable.