Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo una función lambda con SQS como disparador. Cuando la lambda se ejecuta, independientemente de que ocurra un error o no, volverá a poner el trabajo en la cola y creará un bucle. ¿Debo devolver algo en la función lambda para hacer saber a SQS que recibí el mensaje (realicé . . . Read more
max.in.flight.requests.per.connection – Esto controla cuántos lotes de mensajes enviará el productor al servidor sin recibir respuestas. Entonces, asumiendo que tenemos max.in.flight.requests.per.connection = 5. Tenemos enable.idempotence = true. Kafka garantiza el orden con max.in.flight.requests.per.connection <= 5. Kafka almacena números de secuencia para cada mensaje. Y tenemos la siguiente situación con un . . . Read more
Tengo un productor de mensajes que envía mensajes como {“user_id”: 1, “message”: “Ciao”} a una cola SQS. Tengo tres instancias de una API de WebSockets, sus nombres son A, B y C. Digamos que cinco usuarios se conectan a esa API, y sus IDs son 1, 2, 3, 4 y . . . Read more
Estoy suponiendo que la respuesta sería un rotundo “No”. ¿Pero existe alguna manera de publicar mensajes de SQS directamente en un Bucket de S3? Sé que el patrón es SQS -> Lambda -> S3. Pero me preguntaba si había alguna manera de publicar directamente desde SQS a un Bucket de . . . Read more
Esperaría que si la cola SQS especificada en la siguiente anotación no existe, Spring lanzará una excepción NonExistentQueue durante el inicio. @SqsListener(value = “nonExistingQueue”, deletionPolicy = SqsMessageDeletionPolicy.ALWAYS) Pero de alguna manera en mi caso no se lanza ninguna excepción y la aplicación se iniciará sin la cola. ¿Por qué no . . . Read more