Code Review / cps.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: b497249) | patch
KafkaListener config for CloudEvents 54/135154/3
authormpriyank <priyank.maheshwari@est.tech>
Fri, 23 Jun 2023 14:01:38 +0000 (15:01 +0100)
committermpriyank <priyank.maheshwari@est.tech>
Mon, 26 Jun 2023 11:53:00 +0000 (12:53 +0100)
commit93fa06429f8d8e3d5bce25ae4b338156f428888a
treeabdff7cdc396ce989ac733810958bdebb0da50a1tree | snapshot
parentb4972497090332bf9d656b73cf6735846f1e1d5ecommit | diff
KafkaListener config for CloudEvents

- Introduced kafkalistener factory configs to correctly use the configs
  and convert the incoming events to CloudEvents
- Also legacy events to use a separate listener factory
- Increased the wait time from 100ms to 300ms to listen to the message
  in the test

Issue-ID: CPS-1764
Change-Id: I8b9fe0ba82ef87d52b7731941ccd3af8ae980109
Signed-off-by: mpriyank <priyank.maheshwari@est.tech>
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/kafka/KafkaConfig.java [moved from cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/kafka/KafkaTemplateConfig.java with 81% similarity] diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/events/avc/AvcEventConsumer.java diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncDataOperationEventConsumerIntegrationSpec.groovy diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/config/kafka/KafkaConfigSpec.groovy [moved from cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/config/kafka/KafkaTemplateConfigSpec.groovy with 96% similarity] diff | blob | history
"cps"