Losed subscription

[pablobragan]

Hi,

We have a situtation when the app restart and for some reason didn't closed a subscription but did close the client connection. After the app starts again, the subscription connects ok but if I check one of the channels it is appeared to be one subscription tilt with all the pending messages. I restart the application a few times and the channel is like stalled. Even I have disconnected that client the subscription remains and when I hit the endpoint /streaming/channelsz For example: "subscriptions": [ { "client_id": "client-id", "inbox": "_INBOX.kVrYdqnAsSPrXZEKKWVKsi", "ack_inbox": "_INBOX.E5IEx85O0cmdoFtQCnZDi7", "queue_name": "queue-name", "is_durable": true, "is_offline": false, "max_inflight": 550, "ack_wait": 600000, "last_sent": 470060, "pending_count": 74922, "is_stalled": false },

It Is very weird that pending_count is larger than max_inflight and also, the others subscriptions we have on the same channel, same queue_name are almost lazy. I think pending_count there it's not real but affects all my statistics.

The application that consumes messages it's a kubernetes application and every pod have its clientId. When the statefulset is terminated we have a pre-close routine that closes every subscription and then closes nats-streaming client connection, so we don't know how we ended at this state.

I hope you could help me to get a solution to this situation.

Thank you