gerrit.onap Code Review - cps.git/commit

author	mpriyank <priyank.maheshwari@est.tech>
	Wed, 24 Sep 2025 15:45:13 +0000 (16:45 +0100)
committer	mpriyank <priyank.maheshwari@est.tech>
	Wed, 29 Oct 2025 06:03:44 +0000 (06:03 +0000)
commit	bab08c745e60f339107bb8265d2e198702f85742
tree	d96597f9aadf19b7b715a9f432d0068cad5cd7f7	tree \| snapshot
parent	4327287b1fecd093b9b23788da37c6265ab461de	commit \| diff

Implement Exactly Once Semantics for CmAvcEvents flow

- introduced exactly once processing for the Cm Avc Event forwarding
flow
- corresponding unit test and integration test added

Issue-ID: CPS-2984
Change-Id: I4eea7c15fe9c2ebbdb441bff669ced365d17510d
Signed-off-by: mpriyank <priyank.maheshwari@est.tech>

23 files changed:

cps-application/src/main/resources/application.yml		diff \| blob \| history
cps-application/src/test/resources/application.yml		diff \| blob \| history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/config/ExactlyOnceSemanticsKafkaConfig.java	[new file with mode: 0644]	blob
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/config/KafkaConfig.java		diff \| blob \| history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/impl/datajobs/subscription/cmavc/CmAvcEventConsumer.java		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/config/KafkaConfigSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/async/CpsAsyncRequestResponseEventIntegrationSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/async/DataOperationEventConsumerSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/data/utils/DmiDataOperationsHelperSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/datajobs/subscription/cmavc/CmAvcEventConsumerSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/impl/inventory/sync/lcm/EventsProducerSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/utils/events/InventoryEventProducerSpec.groovy		diff \| blob \| history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/utils/events/MessagingBaseSpec.groovy		diff \| blob \| history
cps-service/src/main/java/org/onap/cps/events/EventsProducer.java		diff \| blob \| history
cps-service/src/test/groovy/org/onap/cps/events/EventsProducerSpec.groovy		diff \| blob \| history
docker-compose/docker-compose.yml		diff \| blob \| history
integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy		diff \| blob \| history
integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/data/LegacyBatchDataOperationSpec.groovy		diff \| blob \| history
integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/datajobs/subscription/CmSubscriptionSpec.groovy		diff \| blob \| history
integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/inventory/CmHandleCreateSpec.groovy		diff \| blob \| history
integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/inventory/CmHandleUpdateSpec.groovy		diff \| blob \| history
integration-test/src/test/java/org/onap/cps/integration/KafkaTestContainer.java		diff \| blob \| history
integration-test/src/test/resources/application.yml		diff \| blob \| history

"cps"

RSS Atom