Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy intentando leer datos de GCP pubsub usando DirectChannel (Código de Referencia). Cuando usé directchannel con maxSubscribers ajustado a 1, 2, 5, 10 y 40, 4 hilos comenzaron a procesar mi código para cada unidad de datos proveniente de pubsub, en cada caso. Lo mismo sucedió con PublishSubscribeChannel, donde por . . . Read more
¿El messageId siempre cambia cuando vuelve a la cola después de recibir un rechazo (nack)? He buscado exhaustivamente en la documentación y las preguntas en Stack Overflow y no he encontrado nada al respecto.
Soy nuevo en el mundo de GCP. Estoy tratando de ejecutar uno de los ejemplos de pubsub (https://github.com/googleapis/java-pubsub/blob/HEAD/samples/snippets/src/main/java/pubsub/SubscribeWithAvroSchemaExample.java) en el repositorio de Github de Google en Cloud Shell. Su documentación también tiene enlaces a Cloud Shell (https://github.com/googleapis/java-pubsub/tree/ff9c9c15a9efb10d5cbc9328c7a703a20b5d4b44#samples) Puedo compilar en Cloud Shell ejecutando mvn clean install. Pero cuando ejecuto esa . . . Read more
Tengo un escenario para suscribirme desde un tema de Pubsub, leer la carga útil y publicarla de nuevo en otro tema de PubSub con un atributo adicional basado en la carga útil. No pude encontrar ejemplos para poblar atributos personalizados. ¿Alguien puede ayudar con las opciones o un ejemplo? pipeline.apply( . . . Read more
Estoy ejecutando una serie de cálculos en ~120 tablas. Algoritmo: Leer tabla final, encontrar donde el día = algo y agregar los resultados a una tabla existente. Para table2 en tablearray: { consulta = “SELECT * ” + “FROM (SELECT * FROM tablefinal where day=someday) AS tmp ” + “WHERE . . . Read more