Import is not working

[sarthakgarg814]

Expected behavior

Actual behavior

TypeError: AsyncRetryHelper is not a constructor

Steps to reproduce the behavior

npm install and try

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.

[brianphillips]

@sarthakgarg814 thanks for filing the issue. I'm assuming you are trying to use this module from within an ESM app? Would you mind trying kafkajs-async-retry@1.0.1-alpha.2 and seeing if it fixes the issue for you? I've changed how the NPM module is structured such that it includes both ESM and CJS transpiled versions.

[sarthakgarg814]

Hi @brianphillips,

1. Also one more issue is that we are not using producer.connect() in readme file.
2. Auto Commit commits the message when we read it in retry queue but we sent it in pause state but when we resume the message is already acknowledged, hence we lost the message

Regards
Sarthak Garg

[brianphillips]

@sarthakgarg814 please file a new GitHub issue with more specific instructions (ideally, sample code) that demonstrates the issue(s) you're having. Also, please let me know once you've had a chance to try the version I mentioned and if it works in your environment, I'll release an actual v1.0.1 to fix the export/import issue.