Skip to content

Commit

Permalink
Fix error handling in BackbeatConsumer.js
Browse files Browse the repository at this point in the history
Issue: BB-561
  • Loading branch information
KillianG committed Nov 6, 2024
1 parent c388fc7 commit f3105f9
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions lib/BackbeatConsumer.js
Original file line number Diff line number Diff line change
Expand Up @@ -251,11 +251,8 @@ class BackbeatConsumer extends EventEmitter {
this._consumer.on('event.stats', res => {
const statsObj = safeJsonParse(res.message);
if (statsObj.error) {
this._log.error('error parsing consumer stats', {
error: statsObj.error,
topic: this._topic,
groupId: this._groupId,
});
this._log.error('error parsing consumer stats', { error: statsObj.error, topic: this._topic,
groupId: this._groupId });
return undefined;
}

Expand Down

0 comments on commit f3105f9

Please sign in to comment.