2021-06-24T09:10:49.965708667Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipelineService"},"level":"info","message":"Processing new message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.965827669Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Starting idempotency check","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974564693Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is from processable context, sending further down the pipeline...","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974602293Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Marking incoming message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974697295Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is new, marking it for rest of the pipeline","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974831496Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Processing message for the 1 time","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974952398Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing start","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:50.299849197Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"DTB02","errorName":"NominationCharteringAdviceRepository","loggerName":"DatabaseNotFoundError"},"level":"error","message":"The database could not be found when trying to access it for tenant 48 : Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300110700Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"UXP01","errorName":"CommandExecutionError","loggerName":"ReceiveWithdrawNominationHandler"},"level":"error","message":"ReceiveWithdrawNominationHandler - The execution of the business action failed during the preparation and business logic validation step - prepareAndValidate.","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300395504Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","businessAction":"n.receiveWithdrawNomination","errorType":"UXP01","errorName":"BusinessActionError","loggerName":"ReceiveWithdrawNominationHandler"},"level":"error","message":"ReceiveWithdrawNominationHandler - Business action n.receiveWithdrawNomination failed during execution","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300512306Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"DTB01","errorName":"DatabaseAccessError","loggerName":"ReceiveWithdrawNominationHandler"},"level":"error","message":"ReceiveWithdrawNominationHandler - Business action n.receiveWithdrawNomination failed with error NonRetryableError: for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found - all databases changes have been reverted","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300717009Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"KAF01","errorName":"KafkaMessageReceivedError","loggerName":"KafkaMessageReceivedError"},"level":"error","message":"An error was encountered when receiving a message from kafka for tenant 48 : for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.307026998Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","error":{"name":"NonRetryableError","logger":{"logger":{"_readableState":{"objectMode":true,"highWaterMark":16,"buffer":{"head":null,"tail":null,"length":0},"length":0,"pipes":[{"_writableState":{"objectMode":true,"highWaterMark":16,"finalCalled":false,"needDrain":false,"ending":false,"ended":false,"finished":false,"destroyed":false,"decodeStrings":true,"defaultEncoding":"utf8","length":0,"writing":false,"corked":0,"sync":false,"bufferProcessing":false,"writecb":null,"writelen":0,"bufferedRequest":null,"lastBufferedRequest":null,"pendingcb":5,"prefinished":false,"errorEmitted":false,"bufferedRequestCount":0,"corkedRequestsFree":{"next":null,"entry":null}},"writable":true,"_events":{"unpipe":[null,null,null],"error":[null,null,null],"drain":[null,null],"close":[null,null],"finish":[null,null]},"_eventsCount":6,"_maxListeners":30,"name":"console","stderrLevels":{},"consoleWarnLevels":{},"eol":"\n","levels":{"crit":0,"error":1,"warn":2,"info":3,"verbose":4,"debug":5},"parent":"[Circular]"},{"_writableState":{"objectMode":true,"highWaterMark":16,"finalCalled":false,"needDrain":false,"ending":false,"ended":false,"finished":false,"destroyed":false,"decodeStrings":true,"defaultEncoding":"utf8","length":0,"writing":false,"corked":0,"sync":false,"bufferProcessing":false,"writecb":null,"writelen":0,"bufferedRequest":null,"lastBufferedRequest":null,"pendingcb":5,"prefinished":false,"errorEmitted":false,"bufferedRequestCount":0,"corkedRequestsFree":{"next":null,"entry":null}},"writable":true,"_events":{"unpipe":[null,null,null],"error":[null,null,null],"drain":[null,null],"close":[null,null],"finish":[null,null]},"_eventsCount":6,"level":"debug","winston":{"version":"3.3.3","transports":{},"config":{"cli":{"levels":{"error":0,"warn":1,"help":2,"data":3,"info":4,"debug":5,"prompt":6,"verbose":7,"input":8,"silly":9},"colors":{"error":"red","warn":"yellow","help":"cyan","data":"grey","info":"green","debug":"blue","prompt":"grey","verbose":"cyan","input":"grey","silly":"magenta"}},"npm":{"levels":{"error":0,"warn":1,"info":2,"http":3,"verbose":4,"debug":5,"silly":6},"colors":{"error":"red","warn":"yellow","info":"green","http":"green","verbose":"cyan","debug":"blue","silly":"magenta"}},"syslog":{"levels":{"emerg":0,"alert":1,"crit":2,"error":3,"warning":4,"notice":5,"info":6,"debug":7},"colors":{"emerg":"red","alert":"yellow","crit":"red","error":"red","warning":"red","notice":"yellow","info":"green","debug":"blue"}}},"loggers":{"loggers":{},"options":{}}},"levels":{"crit":0,"error":1,"warn":2,"info":3,"verbose":4,"debug":5},"parent":"[Circular]"}],"pipesCount":2,"flowing":true,"ended":false,"endEmitted":false,"reading":false,"sync":false,"needReadable":true,"emittedReadable":false,"readableListening":false,"resumeScheduled":false,"paused":false,"emitClose":true,"autoDestroy":false,"destroyed":false,"defaultEncoding":"utf8","awaitDrain":0,"readingMore":true,"decoder":null,"encoding":null},"readable":true,"_events":{"end":[null,null],"data":[null,null]},"_eventsCount":3,"_writableState":{"objectMode":true,"highWaterMark":16,"finalCalled":false,"needDrain":false,"ending":false,"ended":false,"finished":false,"destroyed":false,"decodeStrings":true,"defaultEncoding":"utf8","length":1,"writing":true,"corked":0,"sync":true,"bufferProcessing":false,"writelen":1,"bufferedRequest":null,"lastBufferedRequest":null,"pendingcb":6,"prefinished":false,"errorEmitted":false,"emitClose":true,"autoDestroy":false,"bufferedRequestCount":0,"corkedRequestsFree":{"next":null,"entry":null}},"writable":true,"allowHalfOpen":true,"_transformState":{"needTransform":true,"transforming":true,"writechunk":"[Circular]","writeencoding":"utf8"},"format":{"options":{}},"defaultMeta":null,"levels":{"crit":0,"error":1,"warn":2,"info":3,"verbose":4,"debug":5},"level":"info","exceptions":{"logger":"[Circular]","handlers":{}},"rejections":{"logger":"[Circular]","handlers":{}},"profilers":{},"exitOnError":true},"loggerName":"DatabaseNotFoundError","monitoringEnvVarParams":{}}},"errorType":"UXP01","errorName":"ConsumingMessageFailed","loggerName":"ConsumerPipelineService"},"level":"error","message":"Failed to process message","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.307129000Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","MessageStatus":"failed","context":{"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","tenantId":48,"contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9"},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.314542405Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","errorMessage":"for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found","stack":"NonRetryableError: for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found\n at ReceiveWithdrawNominationHandler.prepareAndValidate (/home/node/app/dist/server.js:20642:19)\n at processTicksAndRejections (internal/process/task_queues.js:97:5)\n at async ReceiveWithdrawNominationHandler.stepCall (/home/node/app/dist/server.js:2904:20)\n at async ReceiveWithdrawNominationHandler.execute (/home/node/app/dist/server.js:2870:27)\n at async ProtocolService.processMessage (/home/node/app/dist/server.js:5845:13)\n at async InternalConsumerService.eachMessage (/home/node/app/dist/server.js:12779:13)\n at async MessageProcessingPipe.process (/home/node/app/node_modules/@abc2d/kafka/dist/consumerPipeline/pipes/message-processing-pipe.js:22:9)\n at async ConsumerPipelineService.processMessagePipeline (/home/node/app/node_modules/@abc2d/kafka/dist/consumerPipeline/consumer-pipeline.service.js:94:13)\n at async /home/node/app/node_modules/@abc2d/kafka/dist/consumerPipeline/consumer-pipeline.service.js:70:13","topic":"inbound-interstack-message","partition":0,"offset":"170617","messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","errorType":"UXP01","errorName":"UnrecoverableMsgConsumingFailure","loggerName":"ConsumerFactoryService"},"level":"error","message":"Encountered a non-retryable error in message processing. Message will be moved to DLQ. Manual intervention is required.","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.314683907Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","topic":"inbound-interstack-message","id":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"DlqMessageService"},"level":"info","message":"Upsert dlq message","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.335266998Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","id":"665bd5b5-5d87-40a4-bca4-654579a9c228","topic":"inbound-interstack-message","value":"[REDACTED]","key":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","headers":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427"},"contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","client":null,"metadata":null,"retries":0,"state":"UNPROCESSED","createdAt":"2021-06-24T09:10:50.313Z","updatedAt":"2021-06-24T09:10:50.313Z","loggerName":"DlqMessageService"},"level":"info","message":"Successfully saved new dlq message","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:11:00.046072938Z {"message":"::1 - - [24/Jun/2021:09:11:00 +0000] \"GET /api/dlq-messages/count HTTP/1.1\" 200 12 \"-\" \"Go-http-client/1.1\"\n","level":"info","timestamp":"2021-06-24 09:11:00"}

2021-06-24T09:11:12.815039052Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipelineService"},"level":"info","message":"Processing new message","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:12.815228354Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Starting idempotency check","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:12.823661773Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is from processable context, sending further down the pipeline...","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:12.823805875Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Marking incoming message","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:12.823903576Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is new, marking it for rest of the pipeline","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:12.823992177Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Processing message for the 1 time","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:12.824072479Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing start","timestamp":"2021-06-24 09:11:12"}
2021-06-24T09:11:13.229614267Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"action":"n.receiveWithdrawNomination","voyageBusinessId":"f051232f-9a79-4e2e-93f9-f83598147631","nominationBusinessId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","errorType":"DTB02","errorName":"EventLogCompletionError","loggerName":"NominationHistoryViewConsumer"},"level":"warn","message":"Missing information in event log for current nomination","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.880828001Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","loggerName":"ConsumerFactoryService"},"level":"info","message":"Successfully processed message at partition: 0 offset: 1327465 of topic: topic-domain-events","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.886313078Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","loggerName":"ConsumerPipelineService"},"level":"info","message":"Start processing new kafka message","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.891414449Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipelineService"},"level":"info","message":"Processing new message","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.900371975Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is from processable context, sending further down the pipeline...","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.900519077Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Marking incoming message","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.900580478Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is new, marking it for rest of the pipeline","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.900712580Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Processing message for the 1 time","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.900832481Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing start","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.901151086Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing successful","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.906223457Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipelineService"},"level":"info","message":"Successfully processed message","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:13.906381459Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","MessageStatus":"success","context":{"messageId":"92fd2930-5394-46ec-8308-b179712a9f25","tenantId":48,"contextId":"f051232f-9a79-4e2e-93f9-f83598147631"},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:11:13"}
2021-06-24T09:11:14.133602246Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"action":"n.receiveWithdrawNomination","voyageBusinessId":"f051232f-9a79-4e2e-93f9-f83598147631","nominationBusinessId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing successful","timestamp":"2021-06-24 09:11:14"}
2021-06-24T09:11:14.145894619Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":50,"action":"n.receiveWithdrawNomination","voyageBusinessId":"f051232f-9a79-4e2e-93f9-f83598147631","nominationBusinessId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipelineService"},"level":"info","message":"Successfully processed message","timestamp":"2021-06-24 09:11:14"}
2021-06-24T09:11:14.146021820Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"50","action":"n.receiveWithdrawNomination","voyageBusinessId":"f051232f-9a79-4e2e-93f9-f83598147631","nominationBusinessId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","MessageStatus":"success","context":{"messageId":"bbc3cd59-cdea-4bda-a3c4-9ce3e0cb77f4","tenantId":50,"contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9"},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:11:14"}
2021-06-24T09:11:14.186222184Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"50","action":"n.receiveWithdrawNomination","voyageBusinessId":"f051232f-9a79-4e2e-93f9-f83598147631","nominationBusinessId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerFactoryService"},"level":"info","message":"Successfully processed message at partition: 0 offset: 170619 of topic: inbound-interstack-message","timestamp":"2021-06-24 09:11:14"}
2021-06-24T09:11:14.677018268Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","loggerName":"ConsumerFactoryService"},"level":"info","message":"Successfully processed message at partition: 0 offset: 1327466 of topic: topic-domain-events","timestamp":"2021-06-24 09:11:14"}

Withdraw message recieved in api nom

2021-06-24T09:10:49.963653638Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","loggerName":"ConsumerPipelineService"},"level":"info","message":"Start processing new kafka message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.965708667Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipelineService"},"level":"info","message":"Processing new message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.965827669Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Starting idempotency check","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974564693Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is from processable context, sending further down the pipeline...","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974602293Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Marking incoming message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974697295Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is new, marking it for rest of the pipeline","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974831496Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Processing message for the 1 time","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974952398Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing start","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:50.299849197Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"DTB02","errorName":"NominationCharteringAdviceRepository","loggerName":"DatabaseNotFoundError"},"level":"error","message":"The database could not be found when trying to access it for tenant 48 : Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300110700Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"UXP01","errorName":"CommandExecutionError","loggerName":"ReceiveWithdrawNominationHandler"},"level":"error","message":"ReceiveWithdrawNominationHandler - The execution of the business action failed during the preparation and business logic validation step - prepareAndValidate.","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300395504Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","businessAction":"n.receiveWithdrawNomination","errorType":"UXP01","errorName":"BusinessActionError","loggerName":"ReceiveWithdrawNominationHandler"},"level":"error","message":"ReceiveWithdrawNominationHandler - Business action n.receiveWithdrawNomination failed during execution","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300512306Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"DTB01","errorName":"DatabaseAccessError","loggerName":"ReceiveWithdrawNominationHandler"},"level":"error","message":"ReceiveWithdrawNominationHandler - Business action n.receiveWithdrawNomination failed with error NonRetryableError: for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found - all databases changes have been reverted","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.300717009Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","errorType":"KAF01","errorName":"KafkaMessageReceivedError","loggerName":"KafkaMessageReceivedError"},"level":"error","message":"An error was encountered when receiving a message from kafka for tenant 48 : for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.307026998Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","error":{"name":"NonRetryableError","logger":{"logger":{"_readableState":{"objectMode":true,"highWaterMark":16,"buffer":{"head":null,"tail":null,"length":0},"length":0,"pipes":[{"_writableState":{"objectMode":true,"highWaterMark":16,"finalCalled":false,"needDrain":false,"ending":false,"ended":false,"finished":false,"destroyed":false,"decodeStrings":true,"defaultEncoding":"utf8","length":0,"writing":false,"corked":0,"sync":false,"bufferProcessing":false,"writecb":null,"writelen":0,"bufferedRequest":null,"lastBufferedRequest":null,"pendingcb":5,"prefinished":false,"errorEmitted":false,"bufferedRequestCount":0,"corkedRequestsFree":{"next":null,"entry":null}},"writable":true,"_events":{"unpipe":[null,null,null],"error":[null,null,null],"drain":[null,null],"close":[null,null],"finish":[null,null]},"_eventsCount":6,"_maxListeners":30,"name":"console","stderrLevels":{},"consoleWarnLevels":{},"eol":"\n","levels":{"crit":0,"error":1,"warn":2,"info":3,"verbose":4,"debug":5},"parent":"[Circular]"},{"_writableState":{"objectMode":true,"highWaterMark":16,"finalCalled":false,"needDrain":false,"ending":false,"ended":false,"finished":false,"destroyed":false,"decodeStrings":true,"defaultEncoding":"utf8","length":0,"writing":false,"corked":0,"sync":false,"bufferProcessing":false,"writecb":null,"writelen":0,"bufferedRequest":null,"lastBufferedRequest":null,"pendingcb":5,"prefinished":false,"errorEmitted":false,"bufferedRequestCount":0,"corkedRequestsFree":{"next":null,"entry":null}},"writable":true,"_events":{"unpipe":[null,null,null],"error":[null,null,null],"drain":[null,null],"close":[null,null],"finish":[null,null]},"_eventsCount":6,"level":"debug","winston":{"version":"3.3.3","transports":{},"config":{"cli":{"levels":{"error":0,"warn":1,"help":2,"data":3,"info":4,"debug":5,"prompt":6,"verbose":7,"input":8,"silly":9},"colors":{"error":"red","warn":"yellow","help":"cyan","data":"grey","info":"green","debug":"blue","prompt":"grey","verbose":"cyan","input":"grey","silly":"magenta"}},"npm":{"levels":{"error":0,"warn":1,"info":2,"http":3,"verbose":4,"debug":5,"silly":6},"colors":{"error":"red","warn":"yellow","info":"green","http":"green","verbose":"cyan","debug":"blue","silly":"magenta"}},"syslog":{"levels":{"emerg":0,"alert":1,"crit":2,"error":3,"warning":4,"notice":5,"info":6,"debug":7},"colors":{"emerg":"red","alert":"yellow","crit":"red","error":"red","warning":"red","notice":"yellow","info":"green","debug":"blue"}}},"loggers":{"loggers":{},"options":{}}},"levels":{"crit":0,"error":1,"warn":2,"info":3,"verbose":4,"debug":5},"parent":"[Circular]"}],"pipesCount":2,"flowing":true,"ended":false,"endEmitted":false,"reading":false,"sync":false,"needReadable":true,"emittedReadable":false,"readableListening":false,"resumeScheduled":false,"paused":false,"emitClose":true,"autoDestroy":false,"destroyed":false,"defaultEncoding":"utf8","awaitDrain":0,"readingMore":true,"decoder":null,"encoding":null},"readable":true,"_events":{"end":[null,null],"data":[null,null]},"_eventsCount":3,"_writableState":{"objectMode":true,"highWaterMark":16,"finalCalled":false,"needDrain":false,"ending":false,"ended":false,"finished":false,"destroyed":false,"decodeStrings":true,"defaultEncoding":"utf8","length":1,"writing":true,"corked":0,"sync":true,"bufferProcessing":false,"writelen":1,"bufferedRequest":null,"lastBufferedRequest":null,"pendingcb":6,"prefinished":false,"errorEmitted":false,"emitClose":true,"autoDestroy":false,"bufferedRequestCount":0,"corkedRequestsFree":{"next":null,"entry":null}},"writable":true,"allowHalfOpen":true,"_transformState":{"needTransform":true,"transforming":true,"writechunk":"[Circular]","writeencoding":"utf8"},"format":{"options":{}},"defaultMeta":null,"levels":{"crit":0,"error":1,"warn":2,"info":3,"verbose":4,"debug":5},"level":"info","exceptions":{"logger":"[Circular]","handlers":{}},"rejections":{"logger":"[Circular]","handlers":{}},"profilers":{},"exitOnError":true},"loggerName":"DatabaseNotFoundError","monitoringEnvVarParams":{}}},"errorType":"UXP01","errorName":"ConsumingMessageFailed","loggerName":"ConsumerPipelineService"},"level":"error","message":"Failed to process message","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.307129000Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","action":"n.receiveWithdrawNomination","MessageStatus":"failed","context":{"messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","tenantId":48,"contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9"},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.314542405Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","errorMessage":"for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found","stack":"NonRetryableError: for tenant 48 - Nomination with id 479e9a0a-9ad8-45a4-8f5d-5eb56659cec9 could not be found\n at ReceiveWithdrawNominationHandler.prepareAndValidate (/home/node/app/dist/server.js:20642:19)\n at processTicksAndRejections (internal/process/task_queues.js:97:5)\n at async ReceiveWithdrawNominationHandler.stepCall (/home/node/app/dist/server.js:2904:20)\n at async ReceiveWithdrawNominationHandler.execute (/home/node/app/dist/server.js:2870:27)\n at async ProtocolService.processMessage (/home/node/app/dist/server.js:5845:13)\n at async InternalConsumerService.eachMessage (/home/node/app/dist/server.js:12779:13)\n at async MessageProcessingPipe.process (/home/node/app/node_modules/@abc2d/kafka/dist/consumerPipeline/pipes/message-processing-pipe.js:22:9)\n at async ConsumerPipelineService.processMessagePipeline (/home/node/app/node_modules/@abc2d/kafka/dist/consumerPipeline/consumer-pipeline.service.js:94:13)\n at async /home/node/app/node_modules/@abc2d/kafka/dist/consumerPipeline/consumer-pipeline.service.js:70:13","topic":"inbound-interstack-message","partition":0,"offset":"170617","messageId":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","errorType":"UXP01","errorName":"UnrecoverableMsgConsumingFailure","loggerName":"ConsumerFactoryService"},"level":"error","message":"Encountered a non-retryable error in message processing. Message will be moved to DLQ. Manual intervention is required.","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.314683907Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","topic":"inbound-interstack-message","id":"665bd5b5-5d87-40a4-bca4-654579a9c228","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"DlqMessageService"},"level":"info","message":"Upsert dlq message","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:10:50.335266998Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"action":"n.receiveWithdrawNomination","id":"665bd5b5-5d87-40a4-bca4-654579a9c228","topic":"inbound-interstack-message","value":"[REDACTED]","key":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","headers":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427"},"contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","client":null,"metadata":null,"retries":0,"state":"UNPROCESSED","createdAt":"2021-06-24T09:10:50.313Z","updatedAt":"2021-06-24T09:10:50.313Z","loggerName":"DlqMessageService"},"level":"info","message":"Successfully saved new dlq message","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:11:00.046072938Z {"message":"::1 - - [24/Jun/2021:09:11:00 +0000] \"GET /api/dlq-messages/count HTTP/1.1\" 200 12 \"-\" \"Go-http-client/1.1\"\n","level":"info","timestamp":"2021-06-24 09:11:00"}
2021-06-24T09:11:08.220379206Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","loggerName":"ConsumerPipelineService"},"level":"info","message":"Start processing new kafka message","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.222611838Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipelineService"},"level":"info","message":"Processing new message","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.222735839Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Starting idempotency check","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.231604664Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is from processable context, sending further down the pipeline...","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.231712365Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Marking incoming message","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.231759166Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is new, marking it for rest of the pipeline","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.231859567Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Processing message for the 1 time","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:08.231959469Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing start","timestamp":"2021-06-24 09:11:08"}
2021-06-24T09:11:09.730884793Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"action":"n.receivePrivate","messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing successful","timestamp":"2021-06-24 09:11:09"}
2021-06-24T09:11:09.743690072Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":48,"action":"n.receivePrivate","messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","contextId":"f051232f-9a79-4e2e-93f9-f83598147631","loggerName":"ConsumerPipelineService"},"level":"info","message":"Successfully processed message","timestamp":"2021-06-24 09:11:09"}
2021-06-24T09:11:09.743773474Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","action":"n.receivePrivate","MessageStatus":"success","context":{"messageId":"ac55cc11-6d64-4040-a8a3-8d49d3463c39","tenantId":48,"contextId":"f051232f-9a79-4e2e-93f9-f83598147631"},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:11:09"}
2021-06-24T09:11:09.783788735Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","action":"n.receivePrivate","loggerName":"ConsumerFactoryService"},"level":"info","message":"Successfully processed message at partition: 0 offset: 170618 of topic: inbound-interstack-message","timestamp":"2021-06-24 09:11:09"}
2021-06-24T09:11:10.692687583Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","loggerName":"ConsumerPipelineService"},"level":"info","message":"Start processing new kafka message","timestamp":"2021-06-24 09:11:10"}

api-protocol

receive withdraw message

2021-06-24T09:10:22.607917899Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","loggerName":"ConsumerPipelineService"},"level":"info","message":"Start processing new kafka message","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611091073Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipelineService"},"level":"info","message":"Processing new message","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611272383Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipeline"},"level":"info","message":"Marking incoming message","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611371789Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipeline"},"level":"info","message":"Message is new, marking it for rest of the pipeline","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611488795Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipeline"},"level":"info","message":"Processing message for the 1 time","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611610102Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing start","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611715008Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","loggerName":"InboundNonBlockchainConsumerService"},"level":"info","message":"Consuming inbound non-blockchain message on topic: alpha-communication partition: 0 offset: 57091","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.611822914Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","loggerName":"EncryptedNonBlockchainPayloadHandler"},"level":"info","message":"About to transform payload","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.612545253Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","recipientId":48,"loggerName":"EncryptedNonBlockchainPayloadHandler"},"level":"info","message":"Successfully transformed and validated inbound payload","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.612663560Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","recipient":48,"loggerName":"DecryptHandler"},"level":"info","message":"Handling message decryption","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:22.612746764Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","recipientId":48,"loggerName":"SecurityApiService"},"level":"info","message":"Calling api-security to decrypt the message","timestamp":"2021-06-24 09:10:22"}
2021-06-24T09:10:23.022755593Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","recipientId":48,"loggerName":"DecryptHandler"},"level":"info","message":"Successfully decrypted inbound message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.023060809Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","loggerName":"InboundService"},"level":"info","message":"Successfully parsed inbound message to JSON","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.023998161Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","loggerName":"EncryptedNonBlockchainPayloadHandler"},"level":"info","message":"Successfully validated inbound non-blockchain message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.024128268Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"VerifySignatureHandler"},"level":"info","message":"Verifying signature","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.024259275Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","signingEntityId":60,"loggerName":"SecurityApiService"},"level":"info","message":"Calling api-security to verify the message signature","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.054788253Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"VerifySignatureHandler"},"level":"info","message":"Successfully received verification response for message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.054818854Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"InboundService"},"level":"info","message":"Successfully verified signature for inbound message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.054934561Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"InboundNonBlockchainConsumerService"},"level":"info","message":"Successfully parsed and validated inbound non-blockchain message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.055047567Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"InboundInitialNonBlockchainMessageHandler"},"level":"info","message":"Handling initial message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.419342683Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"InboundInitialNonBlockchainMessageHandler"},"level":"info","message":"Handling new initial message...","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.419443889Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"InboundInitialNonBlockchainMessageHandler"},"level":"info","message":"Saving new msg to the DB","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.449201624Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","id":"fec9babc-f635-454c-9157-dbf4a8beda95","state":"NON_BLOCKCHAIN_INITIAL_STATE","destinationTopic":"inbound-interstack-communication","type":"NON-BLOCKCHAIN","loggerName":"InboundDestinationTopicSender"},"level":"info","message":"Handling NON_BLOCKCHAIN_INITIAL_STATE message state","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.499530189Z {"requestContext":{"0":{"topicName":"inbound-interstack-communication","partition":0,"errorCode":0,"baseOffset":"57089","logAppendTime":"0","logStartOffset":"0"},"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","loggerName":"InternalCommunicationProducerService"},"level":"info","message":"Sent message.","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.499614294Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","id":"fec9babc-f635-454c-9157-dbf4a8beda95","state":"NON_BLOCKCHAIN_INITIAL_STATE","destinationTopic":"inbound-interstack-communication","type":"NON-BLOCKCHAIN","loggerName":"InboundDestinationTopicSender"},"level":"info","message":"Successfully sent msg to topic: inbound-interstack-communication","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.512551605Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","MessageDirection":"inbound","MessageStatus":"success","ProcessingTimeSeconds":0.108,"messageId":"fec9babc-f635-454c-9157-dbf4a8beda95","correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","loggerName":"InboundDestinationTopicSender"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.512660911Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","sender":60,"recipient":48,"correlationId":"a0856b4c-bbba-5c4d-9868-8decb039ff3f","destinationTopic":"inbound-interstack-communication","loggerName":"InboundNonBlockchainConsumerService"},"level":"info","message":"Successfully handled inbound non-blockchain message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.512738415Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing successful","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.519311376Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":48,"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","loggerName":"ConsumerPipelineService"},"level":"info","message":"Successfully processed message","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.519421882Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","MessageStatus":"success","context":{"messageId":"d886ffc0-f64b-41f1-9da0-a1f00b38f530","tenantId":48},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:10:23"}
2021-06-24T09:10:23.555855384Z {"requestContext":{"traceId":"77312e69-4729-4fa9-95e1-3525784ba434","tenantId":"48","loggerName":"CentralCommunicationConsumerFactoryService"},"level":"info","message":"Successfully processed message at partition: 0 offset: 57091 of topic: alpha-communication","timestamp":"2021-06-24 09:10:23"``

receive nomination message in api-protocol

2021-06-24T09:10:48.944656315Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","loggerName":"InboundBlockchainConsumerService"},"level":"info","message":"Consuming inbound blockchain message on topic: alpha partition: 0 offset: 170627","timestamp":"2021-06-24 09:10:48"}
2021-06-24T09:10:48.944710216Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","loggerName":"EncryptedBlockchainPayloadHandler"},"level":"info","message":"About to transform payload","timestamp":"2021-06-24 09:10:48"}
2021-06-24T09:10:48.945185423Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","recipientId":48,"loggerName":"EncryptedBlockchainPayloadHandler"},"level":"info","message":"Successfully transformed and validated inbound payload","timestamp":"2021-06-24 09:10:48"}
2021-06-24T09:10:48.945260224Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","recipient":48,"loggerName":"DecryptHandler"},"level":"info","message":"Handling message decryption","timestamp":"2021-06-24 09:10:48"}
2021-06-24T09:10:48.945327025Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","recipientId":48,"loggerName":"SecurityApiService"},"level":"info","message":"Calling api-security to decrypt the message","timestamp":"2021-06-24 09:10:48"}
2021-06-24T09:10:49.244446859Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","recipientId":48,"loggerName":"DecryptHandler"},"level":"info","message":"Successfully decrypted inbound message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.244675862Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","loggerName":"InboundService"},"level":"info","message":"Successfully parsed inbound message to JSON","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.245371372Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","loggerName":"EncryptedBlockchainPayloadHandler"},"level":"info","message":"Successfully validated inbound blockchain message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.245483473Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"VerifySignatureHandler"},"level":"info","message":"Verifying signature","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.245545674Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","signingEntityId":60,"loggerName":"SecurityApiService"},"level":"info","message":"Calling api-security to verify the message signature","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.273529670Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"VerifySignatureHandler"},"level":"info","message":"Successfully received verification response for message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.273619972Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"InboundService"},"level":"info","message":"Successfully verified signature for inbound message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.273750873Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"InboundBlockchainConsumerService"},"level":"info","message":"Successfully parsed and validated inbound blockchain message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.273858275Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"InboundInitialMessageHandler"},"level":"info","message":"Handling initial message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.278634243Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"InboundInitialMessageHandler"},"level":"info","message":"Handling new initial message...","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.278654843Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"InboundInitialMessageHandler"},"level":"info","message":"Saving new msg to the DB","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.297198305Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","id":"920d6057-3cbc-47a7-be21-d5bff52fdb35","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","state":"PENDING_BLOCKCHAIN_VERIFICATION","type":"BLOCKCHAIN","loggerName":"BlockchainVerificationHandler"},"level":"info","message":"Handling PENDING_BLOCKCHAIN_VERIFICATION message state","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.297290507Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","id":"920d6057-3cbc-47a7-be21-d5bff52fdb35","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","state":"PENDING_BLOCKCHAIN_VERIFICATION","type":"BLOCKCHAIN","loggerName":"BlockchainVerificationHandler"},"level":"info","message":"Verifying the hash of the inbound message is present on the blockchain","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.918123194Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","id":"920d6057-3cbc-47a7-be21-d5bff52fdb35","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","state":"PENDING_BLOCKCHAIN_VERIFICATION","type":"BLOCKCHAIN","event":{"0":"0x1cbfeb76254f24d983a2e1ed199ea328c124ac5cc5be024606c6661547100302","1":"0xf9af14c1be4cb41a429b0cfefba75f8ef8c4455bdf15e3f14335ff0615c0856d","2":"0xB834166F1d67E6D598447758D33B1ccd55910524","keyHash":"0x1cbfeb76254f24d983a2e1ed199ea328c124ac5cc5be024606c6661547100302","payloadHash":"0xf9af14c1be4cb41a429b0cfefba75f8ef8c4455bdf15e3f14335ff0615c0856d","from":"0xB834166F1d67E6D598447758D33B1ccd55910524"},"loggerName":"BlockchainVerificationHandler"},"level":"info","message":"Retrieved event from the blockchain for message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.931528384Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","id":"920d6057-3cbc-47a7-be21-d5bff52fdb35","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","state":"BLOCKCHAIN_VERIFIED","type":"BLOCKCHAIN","loggerName":"BlockchainVerificationHandler"},"level":"info","message":"Successfully verified inbound message hash exists on the blockchain","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.931583484Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","id":"920d6057-3cbc-47a7-be21-d5bff52fdb35","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","state":"BLOCKCHAIN_VERIFIED","type":"BLOCKCHAIN","loggerName":"VerifiedMessageHandler"},"level":"info","message":"Handling BLOCKCHAIN_VERIFIED message state","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.962743925Z {"requestContext":{"0":{"topicName":"inbound-interstack-message","partition":0,"errorCode":0,"baseOffset":"170617","logAppendTime":"0","logStartOffset":"0"},"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","loggerName":"InternalProducerService"},"level":"info","message":"Sent message.","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.962868827Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","id":"920d6057-3cbc-47a7-be21-d5bff52fdb35","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","state":"BLOCKCHAIN_VERIFIED","type":"BLOCKCHAIN","loggerName":"VerifiedMessageHandler"},"level":"info","message":"Successfully sent msg to topic: inbound-interstack-message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.970522235Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","MessageDirection":"inbound","MessageStatus":"success","ProcessingTimeSeconds":0.704,"messageId":"920d6057-3cbc-47a7-be21-d5bff52fdb35","correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","loggerName":"VerifiedMessageHandler"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.970607937Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","sender":60,"recipient":48,"correlationId":"514d31c8-86f0-4510-a513-d5c5b392a8f8","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"InboundBlockchainConsumerService"},"level":"info","message":"Successfully handled inbound blockchain message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.970697338Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"3daa62c5-981e-4eb8-b134-d84ca93a8c43","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipeline"},"level":"info","message":"Main message processing successful","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.974953798Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":48,"messageId":"3daa62c5-981e-4eb8-b134-d84ca93a8c43","contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9","loggerName":"ConsumerPipelineService"},"level":"info","message":"Successfully processed message","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:49.975028499Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","MessageStatus":"success","context":{"messageId":"3daa62c5-981e-4eb8-b134-d84ca93a8c43","tenantId":48,"contextId":"479e9a0a-9ad8-45a4-8f5d-5eb56659cec9"},"loggerName":"ConsumerPipelineService"},"level":"info","message":"metric_data","timestamp":"2021-06-24 09:10:49"}
2021-06-24T09:10:50.001153869Z {"requestContext":{"traceId":"c5e73eb5-4e01-4e3a-8f23-7735b69be427","tenantId":"48","loggerName":"CentralConsumerFactoryService"},"level":"info","message":"Successfully processed message at partition: 0 offset: 170627 of topic: alpha","timestamp":"2021-06-24 09:10:50"}
2021-06-24T09:11:07.252525631Z {"requestContext":{"traceId":"846075b6-a5fb-4d1b-a15a-290a4e79afbe","tenantId":"48","loggerName":"ConsumerPipelineService"},"level":"info","message":"Start processing new kafka message","timestamp":"2021-06-24 09:11:07"}