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.
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
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"
]}
xuyang11@pod-onap-01-vjhost:~/Integration/onap1.1$ curl http://{{dmaap_ip}}:3904/topics/SDC-DISTR-NOTIF-TOPIC-AUTO
{
"owner": "iPIxkpAMI8qTcQj8",
"readerAcl": {
"enabled": true,
"users": [
"BnK5hJIV4npv5AeL",
"E9JOa0uNMZ0q0HFM",
"PgyoAPJXatrJVo2U",
"RDAQ2V1I18s8LRuN",
"RUWqPfyKYBrxttIx",
"fugHmoQTdIaG8RXq",
"k7n8NqBYJsyJDExK",
"mRVu3I4Eg1NKxdQd"
]
},
"name": "SDC-DISTR-NOTIF-TOPIC-AUTO",
"description": "",
"writerAcl": {
"enabled": true,
"users": ["iPIxkpAMI8qTcQj8"]
}
}