Merge pull request #16 from vgenev/fix/reduced-log-verbosity

added transactionId to the logged tags and updated streaming library …

Author: vgenev

package-lock.json

@@ -1,7 +1,7 @@
 {
     "name": "event-sidecar",
     "description": "Event Sidecar is used to route and events to Kafka",
-    "version": "8.7.2",
+    "version": "8.7.3",
     "author": "ModusBox",
     "contributors": [
         "Rajiv Mothilal <rajiv.mothilal@modusbox.com>",
@@ -34,7 +34,7 @@
         "@hapi/vision": "5.5.4",
         "@mojaloop/central-services-logger": "8.6.0",
         "@mojaloop/central-services-metrics": "8.3.0",
-        "@mojaloop/central-services-stream": "8.7.1",
+        "@mojaloop/central-services-stream": "8.7.2",
         "@mojaloop/event-sdk": "8.6.2",
         "blipp": "4.0.1",
         "glob": "7.1.6",

package.json

@@ -56,19 +56,19 @@ const produceMessage = async (messageProtocol, topicConf, config) => {
     if (listOfProducers[topicConf.topicName]) {
       producer = listOfProducers[topicConf.topicName]
     } else {
-      Logger.info('Producer::start::topic=' + topicConf.topicName)
+      Logger.debug('Producer::start::topic=' + topicConf.topicName)
       producer = new Producer(config)
       Logger.info('Producer::connect::start')
       await producer.connect()
       Logger.info('Producer::connect::end')
       listOfProducers[topicConf.topicName] = producer
     }
-    Logger.info(`Producer.sendMessage::messageProtocol:'${JSON.stringify(messageProtocol)}'`)
+    Logger.debug(`Producer.sendMessage::messageProtocol:'${JSON.stringify(messageProtocol)}'`)
     await producer.sendMessage(messageProtocol, topicConf)
-    Logger.info('Producer::end')
+    Logger.debug('Producer::end')
     return true
   } catch (e) {
-    Logger.error(e)
+    Logger.error(e.stack)
     Logger.info(`Producer error has occurred for ${topicConf.topicName}`)
     throw e
   }

src/lib/kafka/producer.js

@@ -105,7 +105,7 @@ const createRPCServer = async () => {
   Logger.info(`GRPC Server started at host: ${grpcServer.host}, port: ${grpcServer.port}`)
   grpcServer.on(eventSDK.EVENT_RECEIVED, async (eventMessage) => {
     Logger.debug('Received eventMessage:', JSON.stringify(eventMessage, null, 2))
-    Logger.info(`Received Event :: type: ${eventMessage.metadata.trace.tags.transactionType} :: action: ${eventMessage.metadata.trace.tags.transactionAction} *** Span :: traceId: ${eventMessage.metadata.trace.traceId} :: spanId: ${eventMessage.metadata.trace.spanId} :: tracestate: ${eventMessage.metadata.trace.tags.tracestate}`)
+    Logger.info(`Received Event :: trancastionId: ${eventMessage.metadata.trace.tags.transactionId} :: type: ${eventMessage.metadata.trace.tags.transactionType} :: action: ${eventMessage.metadata.trace.tags.transactionAction} *** Span :: traceId: ${eventMessage.metadata.trace.traceId} :: spanId: ${eventMessage.metadata.trace.spanId} :: tracestate: ${eventMessage.metadata.trace.tags.tracestate}`)
     await eventHandler.logEvent(eventMessage)
   })
   grpcServer.on('error', async (error) => {