Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
He desarrollado un dispositivo que puede conectarse a Google IoT Core a través del protocolo MQTT, puedo publicar mensajes MQTT en los temas de telemetría (/devices/DEVICE_ID/events). Pero no logro entender cómo suscribir mi dispositivo a un tema genérico y enviar mensajes desde la nube al dispositivo a través de este . . . Read more
Una pregunta sobre el comportamiento de Cloud Pub/Sub: Suponiendo que tengo un tema con ordenamiento de mensajes y una suscripción que maneja el ordenamiento de mensajes. Si tengo más de un consumidor para la suscripción, ¿hay alguna manera de asegurar que el mismo consumidor siempre reciba los mensajes para la . . . Read more
Soy nuevo en Kafka. Estoy usando Spring Cloud Stream Kafka en mi proyecto, también estoy escribiendo código de manera funcional. Quiero consumir un mensaje de un único tema de entrada, construir diferentes modelos a partir del mensaje y publicar cada modelo en un tema diferente (es decir, 1 modelo -> . . . Read more
Escenario 10 consumidores de Kafka dentro de un mismo grupo de consumidores. Kafka tiene 10 particiones => lo que significa que cada partición se asigna automáticamente a un único consumidor dentro del grupo. El mensaje se envía a la partición de forma rotativa. De vez en cuando, un mensaje tardará . . . Read more
Hay dos scripts en un servidor, redis en localhost. Script 1: $redis = new Redis(); $redis->connect($redisHost, $redisPort); while (1) { $redis->publish(‘test-tt’, microtime(true)); } Script 2: $redis = new Redis(); $redis->connect($redisHost, $redisPort); $result = $redis->subscribe([‘test-tt’], ‘redisprocessor’); function redisprocessor($redis, $channel, $message) { print number_format(microtime(true) – $message, 12).”\n”; } Resultados de ejecución: 0.000058889389 . . . Read more