Consumer.acknowledge() not registered in client

After receiving a message, our script makes an API call through axios to process the pulsar message. consumer.receive() and the processing logic runs in a while loop until receive() times out when the queue is empty.

It appears if we run acknowledge() prior to the API call, the client behaves correctly, that is messages are acked and receive does not receive any more messages once all messages are acked.

But running ack after the API call, the desired way to ack the message, it seems as receive() goes in a loop and keeps receiving messages already acked. However if we quit the script and re-run it, the queue is indeed empty and no messages are received, similarly peaking the messages through pulsar-admin for the given topic-partition while the script is running confirm messages are acked.

Bắt đầu bằng cách tái hiện vòng lặp while sử dụng consumer.receive() và acknowledge() xung quanh lệnh gọi xử lý axios, so sánh việc acknowledge trước và sau yêu cầu API. Kiểm tra xem receive() có trả về các message đã được acknowledge cho đến khi timeout hay không, và sử dụng pulsar-admin để so sánh trạng thái topic-partition trong khi client đang chạy. Được xem là hoàn tất khi các acknowledgement sau khi xử lý ngăn không cho các message đó được phân phối thêm mà không cần khởi động lại client.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.