disable idempotence producer

NV4RE · NV4RE · commit 2f8027c5b196 · 2020-08-25T23:40:36.000+07:00
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,

Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ export class Worker extends EventEmitter {`
`148`	`148`	`this.producer = new Producer(`
`149`	`149`	`{`
`150`	`150`	`'compression.type': 'snappy',`
`151`		`- 'enable.idempotence': true,`
	`151`	`+ 'enable.idempotence': false,`
`152`	`152`	`retries: 100,`
`153`	`153`	`'socket.keepalive.enable': true,`
`154`	`154`	`'queue.buffering.max.messages': 100000,`