confluent-kafka-javascript
confluent-kafka-javascript copied to clipboard
Combined PR for latest changes
The change to the run() method is because await run() is expected not to block an async method as per the api.