kafkajs: KafkaJS has UnhandledPromiseRejection somewhere in the code

Was running stress tests on the kafkajs and picked up this issue (error does not matter most important part is UnhandledPromiseRejectionWarning):

(node:78646) UnhandledPromiseRejectionWarning: KafkaJSProtocolError: The coordinator is not aware of this member
    at createErrorFromCode (/Users/dmitrii/Desktop/Projects/at_connector_common/node_modules/kafkajs/src/protocol/error.js:537:10)
    at Object.parse (/Users/dmitrii/Desktop/Projects/at_connector_common/node_modules/kafkajs/src/protocol/requests/heartbeat/v0/response.js:20:11)
    at Connection.send (/Users/dmitrii/Desktop/Projects/at_connector_common/node_modules/kafkajs/src/network/connection.js:317:35)
    at process._tickCallback (internal/process/next_tick.js:68:7)
(node:78646) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 2017)

Looks like heartbeat has unhandled promise or throwing inside async function somewhere

Was running latest BETA version ( “kafkajs”: “1.13.0-beta.15”)

About this issue

Original URL
State: closed
Created 4 years ago
Comments: 17 (15 by maintainers)

Commits related to this issue

Attempt to reproduce #702 — committed to tulios/kafkajs by Nevon 4 years ago

Most upvoted comments

@WaleedAshraf interesting my one is always crashing may be i have different setup…

goriunov on Apr 22, 2020

The code in question has seen quite some changes in the current unreleased version, so that would somewhat be expected I’d say.

ankon on Apr 21, 2020