disable idempotence producer

devit-tel · Aug 25, 2020 · 2f8027c · 2f8027c
1 parent 2cfa0c3
commit 2f8027c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/worker.ts b/src/worker.ts
@@ -148,7 +148,7 @@ export class Worker extends EventEmitter {
     this.producer = new Producer(
       {
         'compression.type': 'snappy',
-        'enable.idempotence': true,
+        'enable.idempotence': false,
         retries: 100,
         'socket.keepalive.enable': true,
         'queue.buffering.max.messages': 100000,