/*
* ============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.
const testEventPayload = JSON.stringify(JSON.parse(open('../../resources/sampleAvcInputEvent.json')));
const schemaRegistry = new SchemaRegistry();
-let messagesSent = 0;
const kafkaProducer = new Writer({
brokers: ['localhost:9092'],
try {
kafkaProducer.produce({messages: messages});
- messagesSent += messages.length;
const isBatchSent = check(kafkaProducer, {
['Batch of ${batchSize} messages sent successfully']: (producer) => producer != null,
});