You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have a use-case where I would like to use my consumer's retry topic to reprocess messages sent to our dead letter topic. I built a service that pulls messages from the DLT and publishes messages directly to the retry topic, but my consumer is not picking up these messages. If I send messages to the original topic and let them retry naturally, it works just fine. It's only an issue if I push directly to the retry topic.
What are the requirements for the consumer to pick up messages from the retry topic? I was thinking that it would pick up anything sent to the retry topic but that doesn't seem to be the case. I've tried sending a dozen headers as well, but nothing has worked so far.
What is the bare minimum that needs to be sent (headers, etc.)?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
I have a use-case where I would like to use my consumer's retry topic to reprocess messages sent to our dead letter topic. I built a service that pulls messages from the DLT and publishes messages directly to the retry topic, but my consumer is not picking up these messages. If I send messages to the original topic and let them retry naturally, it works just fine. It's only an issue if I push directly to the retry topic.
What are the requirements for the consumer to pick up messages from the retry topic? I was thinking that it would pick up anything sent to the retry topic but that doesn't seem to be the case. I've tried sending a dozen headers as well, but nothing has worked so far.
What is the bare minimum that needs to be sent (headers, etc.)?
Beta Was this translation helpful? Give feedback.
All reactions