changing debug to error and changing version

Author: himanshu219

lambda-extensions/config/version.go

@@ -8,7 +8,7 @@ import (
 
 // ExtensionName same as binary name or file name where main exists
 var ExtensionName = filepath.Base(os.Args[0])
-var layerVersion = "2"
+var layerVersion = "1"
 
 // SumoLogicExtensionLayerVersionSuffix denotes the layer version published in AWS
 var SumoLogicExtensionLayerVersionSuffix string = fmt.Sprintf("%s-prod:%s", ExtensionName, layerVersion)

lambda-extensions/workers/consumer.go

@@ -47,7 +47,7 @@ func (sc *sumoConsumer) FlushDataQueue(ctx context.Context) {
 			default:
 				err := sc.sumoclient.FlushAll(rawMsgArr)
 				if err != nil {
-					sc.logger.Debugln("Unable to flush DataQueue", err.Error())
+					sc.logger.Errorln("Unable to flush DataQueue", err.Error())
 					// putting back all the msg to the queue in case of failure
 					for _, msg := range rawMsgArr {
 						sc.dataQueue <- msg