We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3343ba4 commit e910dccCopy full SHA for e910dcc
extensions/gc/GarbageCollectorProducer.js
@@ -30,8 +30,16 @@ class GarbageCollectorProducer {
30
requiredAcks: this._kafkaConfig.requiredAcks,
31
topic: this._topic,
32
});
33
- producer.once('error', () => {});
+ producer.once('error', err => {
34
+ this._log.error('error from GarbageCollectorProducer backbeat producer', {
35
+ topic: this._topic,
36
+ error: err,
37
+ errmsg: err.toString(),
38
+ });
39
+ cb(err);
40
41
producer.once('ready', () => {
42
+ this._log.info('GarbageCollectorProducer backbeat producer ready');
43
producer.removeAllListeners('error');
44
producer.on('error', err =>
45
this._log.error('error from backbeat producer', {
0 commit comments