DMAAP Component

Kafka command to log dmaap messages (Working for Casablanca only)

Kafka command to show message

root@oom-rancher:~# kubectl -n onap exec -it dev-dmaap-message-router-kafka-64465d9ff4-87z7r bash
bash-4.4# /opt/kafka_2.12-0.11.0.1/bin/kafka-console-consumer.sh --topic SDC-DISTR-NOTIF-TOPIC-AUTO --bootstrap-server localhost:9092
{
  "distributionID": "e57cb847-2d7b-41dd-a023-a2c6d5e9567b",
  "serviceName": "demoVCPEInfra",
  "serviceVersion": "2.0",
  "serviceUUID": "814c0142-720e-4632-a18d-e6716ab0cfbe",
  "serviceDescription": "catalog service description",
  "serviceInvariantUUID": "25fbbd01-3829-49cd-989e-3eece7640631",
  "resources": [
    {
      "resourceInstanceName": "CPE_SIGNAL",
      "resourceName": "Generic NeutronNet",
      "resourceVersion": "1.0",
      "resoucreType": "VF",
      "resourceUUID": "99b4e639-9029-4b61-95d0-b487a027baea",
      "resourceInvariantUUID": "cb7175a9-ece9-4740-ba14-886385012bb5",
      "resourceCustomizationUUID": "1ebbdd11-a1df-4d81-a3e4-b6261c384e93",
      "category": "Generic",
      "subcategory": "Network Elements",
      "artifacts": []
    },
    {
      "resourceInstanceName": "bcb24384-5a28-4e09-8999 0",
      "resourceName": "bcb24384-5a28-4e09-8999",
      "resourceVersion": "1.0",
      "resoucreType": "VF",
      "resourceUUID": "27569ee4-e718-4ea4-a9a3-b53d97162a71",
      "resourceInvariantUUID": "e95d3e4b-49d9-481c-b117-a116388a0c43",
      "resourceCustomizationUUID": "f3376f12-4977-43f2-90ba-a06e66e8a57e",
      "category": "Generic",
      "subcategory": "Abstract",
      "artifacts": [
        {
          "artifactName": "vf-license-model.xml",
          "artifactType": "VF_LICENSE",
          "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/resourceInstances/bcb243845a284e0989990/artifacts/vf-license-model.xml",
          "artifactChecksum": "MzdkMDA1ZTJlMTA3ODlkNzk5NjM0NWIzZDlkYTRkZDI=",
          "artifactDescription": "VF license file",
          "artifactTimeout": 120,
          "artifactUUID": "ffd8b1c1-94ae-43a8-9f32-259482aa0659",
          "artifactVersion": "1"
        },
        {
          "artifactName": "bcb243845a284e0989990_modules.json",
          "artifactType": "VF_MODULES_METADATA",
          "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/resourceInstances/bcb243845a284e0989990/artifacts/bcb243845a284e0989990_modules.json",
          "artifactChecksum": "MjU3OWRlMWQ5YmJiYWM0Y2ZhOTgyOGFhOGIzODYwMjA=",
          "artifactDescription": "Auto-generated VF Modules information artifact",
          "artifactTimeout": 120,
          "artifactUUID": "2a6a546a-435f-4037-808a-2c39745186a8",
          "artifactVersion": "2"
        },
        {
          "artifactName": "base_vcpe_infra.yaml",
          "artifactType": "HEAT",
          "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/resourceInstances/bcb243845a284e0989990/artifacts/base_vcpe_infra.yaml",
          "artifactChecksum": "ZGEyNDgwNmEzZDk3ODU3ZDg3YTg1MDc0NmU1ZTMwYmI=",
          "artifactDescription": "created from csar",
          "artifactTimeout": 120,
          "artifactUUID": "712d63e7-b8ac-4abe-8033-3a025147001d",
          "artifactVersion": "2"
        },
        {
          "artifactName": "vendor-license-model.xml",
          "artifactType": "VENDOR_LICENSE",
          "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/resourceInstances/bcb243845a284e0989990/artifacts/vendor-license-model.xml",
          "artifactChecksum": "YTYyMDcyODNiYTQzZWFjNzhjYzNkZjA1ZGFkNWY2NDE=",
          "artifactDescription": " Vendor license file",
          "artifactTimeout": 120,
          "artifactUUID": "6dd37037-36b2-4d9b-ab4a-74fa8d7ed44b",
          "artifactVersion": "1"
        },
        {
          "artifactName": "base_vcpe_infra.env",
          "artifactType": "HEAT_ENV",
          "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/resourceInstances/bcb243845a284e0989990/artifacts/base_vcpe_infra.env",
          "artifactChecksum": "ZmJmYjYwNTNiMDIzODlmODUyY2EwNjgyNWM2Y2M3N2E=",
          "artifactDescription": "Auto-generated HEAT Environment deployment artifact",
          "artifactTimeout": 120,
          "artifactUUID": "ae8e5bf7-7ea1-4d26-a8bf-13ed5e0ddfaf",
          "artifactVersion": "3",
          "generatedFromUUID": "712d63e7-b8ac-4abe-8033-3a025147001d"
        }
      ]
    },
    {
      "resourceInstanceName": "Generic NeutronNet 0",
      "resourceName": "Generic NeutronNet",
      "resourceVersion": "1.0",
      "resoucreType": "VL",
      "resourceUUID": "99b4e639-9029-4b61-95d0-b487a027baea",
      "resourceInvariantUUID": "cb7175a9-ece9-4740-ba14-886385012bb5",
      "resourceCustomizationUUID": "f0e15b63-9ad7-48ae-a5da-230f46984745",
      "category": "Generic",
      "subcategory": "Network Elements",
      "artifacts": []
    },
    {
      "resourceInstanceName": "CPE_PUBLIC",
      "resourceName": "Generic NeutronNet",
      "resourceVersion": "1.0",
      "resoucreType": "VF",
      "resourceUUID": "99b4e639-9029-4b61-95d0-b487a027baea",
      "resourceInvariantUUID": "cb7175a9-ece9-4740-ba14-886385012bb5",
      "resourceCustomizationUUID": "82c98813-464a-4169-a8f6-badf8adfd5d5",
      "category": "Generic",
      "subcategory": "Network Elements",
      "artifacts": []
    }
  ],
  "serviceArtifacts": [
    {
      "artifactName": "service-Demovcpeinfra-template.yml",
      "artifactType": "TOSCA_TEMPLATE",
      "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/artifacts/service-Demovcpeinfra-template.yml",
      "artifactChecksum": "M2I0MmMwNzNjMDY2Yzk2ODIyY2M1YjNiZWU5NTBiNWU=",
      "artifactDescription": "TOSCA representation of the asset",
      "artifactTimeout": 0,
      "artifactUUID": "2e269d35-1762-4aee-a4f3-5699f0c59113",
      "artifactVersion": "2"
    },
    {
      "artifactName": "service-Demovcpeinfra-csar.csar",
      "artifactType": "TOSCA_CSAR",
      "artifactURL": "/sdc/v1/catalog/services/Demovcpeinfra/2.0/artifacts/service-Demovcpeinfra-csar.csar",
      "artifactChecksum": "YjdkNTJjMGYwNTIyNTc3Yjg4MDFlMTE4NTYwM2YzZTY=",
      "artifactDescription": "TOSCA definition package of the asset",
      "artifactTimeout": 0,
      "artifactUUID": "d446f0dc-9de3-4c07-918f-4351da933fe2",
      "artifactVersion": "2"
    }
  ],
  "workloadContext": "Production"
}

Simple command to test DMAAP pub/sub. Message body can be any valid JSON file. You may need to post a couple times to register the topic.

Pub/Sub Test

root@onap-oom-rancher:~# cat /tmp/test.json 
{
  "sdc-connections":{
    "sdc-controller":{
        "user": "clamp",
        "consumerGroup": "clamp"
    }
  }
}
root@oom-rancher:~/oom/kubernetes# curl -X POST -H 'Content-Type: application/json' -d @/tmp/test.json http://10.12.6.110:30227/events/unauthenticated.VES_MEASUREMENT_OUTPUT
{
"serverTimeMs": 0,
"count": 1
}
root@oom-rancher:~/oom/kubernetes# curl http://10.12.6.110:30227/events/unauthenticated.VES_MEASUREMENT_OUTPUT/group1/C1?timeout=50000

List DMAAP Topics

xuyang11@pod-onap-01-vjhost:~/Integration/onap1.1$ curl http://{{dmaap_ip}}:3904/topics 
{"topics": [ 
"ECOMP-PORTAL-OUTBOX-APP1", 
"ECOMP-PORTAL-OUTBOX-POL1", 
"SDC-DISTR-STATUS-TOPIC-AUTO", 
"msgrtr.apinode.metrics.dmaap", 
"APPC-CL", 
"PDPD-CONFIGURATION", 
"POLICY-CL-MGT", 
"SDC-DISTR-NOTIF-TOPIC-SDC-OPENSOURCE-ENV1", 
"unauthenticated.CL_OUTPUT", 
"SDC-DISTR-NOTIF-TOPIC-AUTO", 
"unauthenticated.SEC_MEASUREMENT_OUTPUT", 
"SDC-DISTR-STATUS-TOPIC-SDC-OPENSOURCE-ENV1", 
"ECOMP-PORTAL-OUTBOX-VID1", 
"ECOMP-PORTAL-INBOX", 
"ECOMP-PORTAL-OUTBOX-SDC1", 
"unauthenticated.TCA_EVENT_OUTPUT", 
"DCAE-CL-EVENT", 
"APPC-TEST2", 
"APPC-TEST1", 
"ECOMP-PORTAL-OUTBOX-DBC1" 
]}

ONAP Wiki

DMAAP Component

Kafka command to show message

Pub/Sub Test

List DMAAP Topics

Show a Topic Detail