fixup test GC

Author: BourgoisMickael

extensions/gc/GarbageCollectorProducer.js

@@ -30,8 +30,16 @@ class GarbageCollectorProducer {
             requiredAcks: this._kafkaConfig.requiredAcks,
             topic: this._topic,
         });
-        producer.once('error', () => {});
+        producer.once('error', err => {
+            this._log.error('error from GarbageCollectorProducer backbeat producer', {
+                topic: this._topic,
+                error: err,
+                errmsg: err.toString(),
+            });
+            cb(err);
+        });
         producer.once('ready', () => {
+            this._log.info('GarbageCollectorProducer backbeat producer ready');
             producer.removeAllListeners('error');
             producer.on('error', err =>
                 this._log.error('error from backbeat producer', {

lib/BackbeatProducer.js

@@ -15,7 +15,7 @@ const {
     KAFKA_PRODUCER_DEFAULT_COMPRESSION_TYPE,
     KAFKA_PRODUCER_DEFAULT_REQUIRED_ACKS,
 } = require('./config.joi');
-const FLUSH_TIMEOUT = 5000;
+const FLUSH_TIMEOUT = 10000;
 
 
 class BackbeatProducer extends EventEmitter {

tests/functional/replication/queueProcessor.js

@@ -23,6 +23,7 @@ const ReplicationStatusProcessor = require('../../../extensions/replication' +
 
 /* eslint-disable max-len */
 
+werelogs.configure({ level: 'trace' });
 
 function getMD5(body) {
     return crypto.createHash('md5').update(body).digest('hex');
@@ -1566,7 +1567,7 @@ describe('GC should be created if config is provided', () => {
     });
 
     it('should not create a GC if config is not provided', function (done) {
-        this.timeout(60000);
+        this.timeout(120000);
         const replicationStatusProcessor = new ReplicationStatusProcessor(
             { hosts: 'localhost:9092' },
             { auth: { type: 'role',