From ae588292c67e20c5cae8cb3c899957aac79a676d Mon Sep 17 00:00:00 2001 From: Julien Fontaine Date: Mon, 15 Feb 2021 18:31:24 -0500 Subject: Assign a unique worker ID for CDS Kafka worker * Modified CDS Kafka workers to add the 5 lasts characters of the env var HOSTNAME to their worker ID. * Small refactoring to move some utilitary functions to BlueprintMessageUtils Issue-ID: CCSDK-3204 Signed-off-by: Julien Fontaine Change-Id: Iaacd35e9cbe4705d17548518040c679185eaf30a --- .../selfservice/api/BlueprintProcessingKafkaConsumer.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'ms/blueprintsprocessor/modules/inbounds') diff --git a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt index 661e76b2b..82fd78efe 100644 --- a/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt +++ b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/BlueprintProcessingKafkaConsumer.kt @@ -116,7 +116,7 @@ open class BlueprintProcessingKafkaConsumer( "leaderEpoch(${message.leaderEpoch().get()}) " + "offset(${message.offset()}) " + "key(${message.key()}) " + - "CBA(${executionServiceInput.actionIdentifiers.blueprintName}/${executionServiceInput.actionIdentifiers.blueprintVersion}/${executionServiceInput.actionIdentifiers.actionName})" + BlueprintMessageUtils.getMessageLogData(executionServiceInput) ) val executionServiceOutput = executionServiceHandler.doProcess(executionServiceInput) blueprintMessageProducerService.sendMessage(key, executionServiceOutput) -- cgit 1.2.3-korg