producer.connect() Missing in readme/ Example - Githubissues

shutterstock / kafkajs-async-retry

Provides a KafkaJS-compatible handler for processing messages that facilitates publishing to delayed-retry or dead-letter topics

MIT License

15 stars 2 forks source link

producer.connect() Missing in readme/ Example #364

Closed sarthakgarg814 closed 5 months ago

sarthakgarg814 commented 5 months ago

Expected behavior

As your example in readme.md you didn't mention to connect to producer.connect(). It should have it and on error it should send message to next queue

Actual behavior

Without connecting to producer you will not be able to send message to next topic or retry topic. So its failing to send the message in next queue

Steps to reproduce the behavior

Connect to Kafka cluster '...'
Configure consumer with '...'
Publish message '....'
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 commented 5 months ago

Merged in Main, So closing this now