winding handlerConcurrency to 1 at a time to work around ES concurrency conflicts. we shall see if this works...

cwdcwd · cwdcwd · commit ae6a6046a3ca · 2018-08-30T14:27:48.000-04:00
diff --git a/src/app.js b/src/app.js
@@ -12,7 +12,7 @@ const ProcessorService = require('./services/ProcessorService')
 const healthcheck = require('topcoder-healthcheck-dropin')
 
 // create consumer
-const options = { connectionString: config.KAFKA_URL }
+const options = { connectionString: config.KAFKA_URL, handlerConcurrency: 1 }
 if (config.KAFKA_CLIENT_CERT && config.KAFKA_CLIENT_CERT_KEY) {
   options.ssl = { cert: config.KAFKA_CLIENT_CERT, key: config.KAFKA_CLIENT_CERT_KEY }
 }

Original file line number	Diff line number	Diff line change
`@@ -12,7 +12,7 @@ const ProcessorService = require('./services/ProcessorService')`
`12`	`12`	`const healthcheck = require('topcoder-healthcheck-dropin')`
`13`	`13`
`14`	`14`	`// create consumer`
`15`		`-const options = { connectionString: config.KAFKA_URL }`
	`15`	`+const options = { connectionString: config.KAFKA_URL, handlerConcurrency: 1 }`
`16`	`16`	`if (config.KAFKA_CLIENT_CERT && config.KAFKA_CLIENT_CERT_KEY) {`
`17`	`17`	`options.ssl = { cert: config.KAFKA_CLIENT_CERT, key: config.KAFKA_CLIENT_CERT_KEY }`
`18`	`18`	`}`