apache / apache/pulsar-client-node
Waiting for ack
- Lenguaje dominante
- C++
- Estrellas
- 164
- Forks
- 98
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Descripción
I'm trying to consume 1 message at a time, and i'm acknowledging the message outside of the listener. But it's just grabbing the next message without waiting for the ack.
code sample:
```js
let msg;
let msgConsumer;
const consumer = client.subscribe({
topic: `persistent://public/default/test1`,
subscription: `sub1`,
subscriptionType: 'Exclusive',
receiverQueueSize:0,
ackTimeoutMs:300000,
listener: (msg,msgConsumer) => {
console.log(msg.getData().toString());
msg = msg;
msgConsumer = msgConsumer;
}
});
function someWhereElse(){
msgConsumer.acknowledge(msg);
}
```
Is something like this possible?
Guía de contribución
No hay ninguna guía de contribución indexada para este repositorio
Línea de trabajo
Comienza por el listener de suscripción y el flujo de acknowledgements del cliente NodeJS que se muestran en el ejemplo, comprobando cómo se gestionan receiverQueueSize: 0 y los acknowledgements realizados fuera del listener. Reproduce la suscripción con un solo mensaje en vuelo y determina si el siguiente mensaje llega antes de acknowledge(msg); se considera terminado cuando se corrige la secuencia o se documenta el comportamiento admitido.
Escrito por el modelo de indexación a partir del texto del issue.
Evaluación
- Stack tecnológico
- javascript, nodejs
- Área
- distributed-systems
- Tipo de issue
- Error
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Estado de actividad
- Estancado
- Claridad
- Necesita aclaración
- Aptitud para principiantes
- 25/100