Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

RetryQueue failure #365

Open
sarthakgarg814 opened this issue May 29, 2024 · 1 comment
Open

RetryQueue failure #365

sarthakgarg814 opened this issue May 29, 2024 · 1 comment

Comments

@sarthakgarg814
Copy link
Contributor

Expected behavior

When we pause the queue we should not miss the message which we read for checking the time . Also when we resume we should first read that message.

Actual behavior

Auto Commit in kafkajs commits the message when we read it in retry queue but as we paused the state and when we resume the consumer message is already acknowledged last time, hence we lost the message

Steps to reproduce the behavior

  1. Connect to Kafka cluster '...'
  2. Configure consumer with '...'
  3. Publish message '....'
  4. See error

Supporting materials

Additional Specs

  • Node.js version [e.g. 18.1.0]
  • Kafka version [e.g. 3.2.0]
  • KafkaJS version [e.g. 2.1.0]

Additional context
Add any other context about the problem here.

@sarthakgarg814
Copy link
Contributor Author

sarthakgarg814 commented May 29, 2024

Hi @brianphillips ,

I hope you're doing well.

I'd like to discuss the caveats and issues I've identified so that we can work on them together. Could you please send me a meeting invite at your earliest convenience based on your availability? You can reach me at [email protected].

Looking forward to your response.

Best regards,
Sarthak Garg

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant