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 e910dcc commit 2dc609fCopy full SHA for 2dc609f
lib/BackbeatProducer.js
@@ -15,7 +15,7 @@ const {
15
KAFKA_PRODUCER_DEFAULT_COMPRESSION_TYPE,
16
KAFKA_PRODUCER_DEFAULT_REQUIRED_ACKS,
17
} = require('./config.joi');
18
-const FLUSH_TIMEOUT = 5000;
+const FLUSH_TIMEOUT = 10000;
19
20
21
class BackbeatProducer extends EventEmitter {
0 commit comments