From 0fd779c3ff7e62527375e0cb318e98f892f1bfa6 Mon Sep 17 00:00:00 2001 From: emaclee Date: Fri, 2 May 2025 13:23:37 +0100 Subject: [PATCH] Add non blocking comments from previous commit - Adding non blocking comments changes from 140838: Increase CM Notification Event KPI Background Load | https://gerrit.onap.org/r/c/cps/+/140838 Issue-ID: CPS-2752 Change-Id: I14c28466f69d9ff83692075f4283b7631e947fd3 Signed-off-by: emaclee --- k6-tests/ncmp/common/produce-avc-event.js | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/k6-tests/ncmp/common/produce-avc-event.js b/k6-tests/ncmp/common/produce-avc-event.js index 53ddb563b1..4f25b4697f 100644 --- a/k6-tests/ncmp/common/produce-avc-event.js +++ b/k6-tests/ncmp/common/produce-avc-event.js @@ -1,6 +1,6 @@ /* * ============LICENSE_START======================================================= - * Copyright (C) 2024-2025 Nordix Foundation + * Copyright (C) 2024-2025 OpenInfra Foundation Europe. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -24,7 +24,6 @@ import {Writer, SchemaRegistry, SCHEMA_TYPE_STRING} from 'k6/x/kafka'; const testEventPayload = JSON.stringify(JSON.parse(open('../../resources/sampleAvcInputEvent.json'))); const schemaRegistry = new SchemaRegistry(); -let messagesSent = 0; const kafkaProducer = new Writer({ brokers: ['localhost:9092'], @@ -75,7 +74,6 @@ export function sendBatchOfKafkaMessages(batchSize = 250) { try { kafkaProducer.produce({messages: messages}); - messagesSent += messages.length; const isBatchSent = check(kafkaProducer, { ['Batch of ${batchSize} messages sent successfully']: (producer) => producer != null, }); -- 2.16.6