X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=cps-ncmp-service%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fcps%2Fncmp%2Fapi%2Fimpl%2Fnotifications%2Favc%2FAvcEventConsumer.java;h=58290a7e9d24ff354415eeb40cfc4be2e3f357d1;hb=f0d50b68c2696b41f1886e704145a1edfa343750;hp=79a36bf506c1720eb5e9406e8a0b137be16d0d2c;hpb=f0f4fd810c9a249d78def4c2f10356fceb864b1f;p=cps.git diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java index 79a36bf50..58290a7e9 100644 --- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java +++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/notifications/avc/AvcEventConsumer.java @@ -44,7 +44,7 @@ public class AvcEventConsumer { * @param avcEvent the event to be consumed and produced. */ @KafkaListener( - topics = "dmi-cm-events", + topics = "${app.dmi.cm-events.topic}", properties = {"spring.json.value.default.type=org.onap.cps.ncmp.event.model.AvcEvent"}) public void consumeAndForward(final AvcEvent avcEvent) { log.debug("Consuming AVC event {} ...", avcEvent);