feat(backend/sink): added error log for consumer.Commit() method

backend/cmd/sink/main.go

@@ -78,18 +78,20 @@ func main() {
 		select {
 		case sig := <-sigchan:
 			log.Printf("Caught signal %v: terminating\n", sig)
-			consumer.Commit()
+			if err := consumer.Commit(); err != nil {
+				log.Printf("can't commit messages: %s", err)
+			}
 			consumer.Close()
 			os.Exit(0)
 		case <-tick:
 			if err := writer.SyncAll(); err != nil {
 				log.Fatalf("Sync error: %v\n", err)
 			}
-
 			log.Printf("%v messages during 30 sec", count)
 			count = 0
-
-			consumer.Commit()
+			if err := consumer.Commit(); err != nil {
+				log.Printf("can't commit messages: %s", err)
+			}
 		default:
 			err := consumer.ConsumeNext()
 			if err != nil {

scripts/helmcharts/openreplay/charts/sink/templates/deployment.yaml

@@ -54,7 +54,7 @@ spec:
             # 4. Using AWS itself.
             # AWS uses bucketname.endpoint/object while others use endpoint/bucketname/object
             - name: ASSETS_ORIGIN
-            {{ - if eq .Values.global.s3.endpoint "http://minio.db.svc.cluster.local:9000" }}
+            {{- if eq .Values.global.s3.endpoint "http://minio.db.svc.cluster.local:9000" }}
             {{- range $key, $val := .Values.env }}
             - name: {{ $key }}
               value: '{{ $val }}'