Kafka auto commits can now also be set to undefined via env vars

Fortify-Labs · Feb 24, 2021 · c932705 · c932705
1 parent 40c37a8
commit c932705
Show file tree

Hide file tree

Showing 8 changed files with 25 additions and 13 deletions.
diff --git a/devops/kubernetes/src/cluster.ts b/devops/kubernetes/src/cluster.ts
@@ -496,7 +496,7 @@ export class Cluster extends Chart {
 				numberOfInstances: 3,
 				teamId: "fortify",
 				volume: {
-					size: "5Gi",
+					size: "10Gi",
 				},
 				users: {
 					fortify: ["SUPERUSER", "CREATEDB"],

diff --git a/devops/kubernetes/src/fortify.ts b/devops/kubernetes/src/fortify.ts
@@ -410,8 +410,8 @@ export class Fortify extends Chart {
 			configmaps: [redisConfig, kafkaConfig, postgresConfig, vaultConfig],
 			resources: {
 				limits: {
-					cpu: "0.2",
-					memory: "256Mi",
+					cpu: "1",
+					memory: "512Mi",
 				},
 				requests: {
 					cpu: "0.1",

diff --git a/services/fsm/package-lock.json b/services/fsm/package-lock.json
diff --git a/services/fsm/package.json b/services/fsm/package.json
@@ -1,6 +1,6 @@
 {
   "name": "fsm",
-  "version": "1.14.8",
+  "version": "1.14.9",
   "description": "Finite State Machine",
   "author": {
     "name": "Thomas Kosiewski"

diff --git a/services/fsm/src/index.ts b/services/fsm/src/index.ts
@@ -96,8 +96,14 @@ const {
 
 	await consumer.run({
 		autoCommit: KAFKA_AUTO_COMMIT !== "false",
-		autoCommitInterval: parseInt(KAFKA_AUTO_COMMIT_INTERVAL),
-		autoCommitThreshold: parseInt(KAFKA_AUTO_COMMIT_THRESHOLD),
+		autoCommitInterval:
+			KAFKA_AUTO_COMMIT_INTERVAL === "undefined"
+				? undefined
+				: parseInt(KAFKA_AUTO_COMMIT_INTERVAL),
+		autoCommitThreshold:
+			KAFKA_AUTO_COMMIT_THRESHOLD === "undefined"
+				? undefined
+				: parseInt(KAFKA_AUTO_COMMIT_THRESHOLD),
 		eachBatchAutoResolve: KAFKA_EACH_BATCH_AUTO_RESOLVE !== "false",
 		eachBatch: async ({
 			batch,

diff --git a/services/historization/package-lock.json b/services/historization/package-lock.json
diff --git a/services/historization/package.json b/services/historization/package.json
@@ -1,6 +1,6 @@
 {
   "name": "historization",
-  "version": "1.12.10",
+  "version": "1.12.11",
   "description": "A historization service responsible for persisting info",
   "author": {
     "name": "Thomas Kosiewski"

diff --git a/services/historization/src/index.ts b/services/historization/src/index.ts
@@ -87,8 +87,14 @@ const {
 
 	await consumer.run({
 		autoCommit: KAFKA_AUTO_COMMIT !== "false",
-		autoCommitInterval: parseInt(KAFKA_AUTO_COMMIT_INTERVAL),
-		autoCommitThreshold: parseInt(KAFKA_AUTO_COMMIT_THRESHOLD),
+		autoCommitInterval:
+			KAFKA_AUTO_COMMIT_INTERVAL === "undefined"
+				? undefined
+				: parseInt(KAFKA_AUTO_COMMIT_INTERVAL),
+		autoCommitThreshold:
+			KAFKA_AUTO_COMMIT_THRESHOLD === "undefined"
+				? undefined
+				: parseInt(KAFKA_AUTO_COMMIT_THRESHOLD),
 		eachBatchAutoResolve: KAFKA_EACH_BATCH_AUTO_RESOLVE !== "false",
 		eachBatch: async ({
 			batch,