Merge "Make use of Kafka Key for Audit service and Kafka listener"

diff --cc ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
index 12cadfa,93885bf..145c37b
--- 1/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
--- 2/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
+++ b/ms/blueprintsprocessor/modules/inbounds/selfservice-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/selfservice/api/KafkaPublishAuditService.kt
@@@ -106,11 -93,11 +106,11 @@@ class KafkaPublishAuditService
          val key = executionServiceOutput.actionIdentifiers.blueprintName
          try {
              this.outputInstance = this.getOutputInstance(OUTPUT_SELECTOR)
-             this.outputInstance!!.sendMessage(executionServiceOutput)
+             this.outputInstance!!.sendMessage(key, executionServiceOutput)
          } catch (e: Exception) {
              var errMsg =
 -                if (e.message != null) "ERROR : $e"
 -                else "ERROR : Failed to send execution request to Kafka."
 +                    if (e.message != null) "ERROR : $e"
 +                    else "ERROR : Failed to send execution request to Kafka."
              log.error(errMsg)
          }
      }